Hi,
Which version of ceph are you using?
Yuval
On Wed, Mar 11, 2020 at 6:59 AM 曹 海旺 <caohaiwang(a)hotmail.com> wrote:
HI,
I'm sorry to bother you again
I want to use kafka to queue the notifications , I add a topic named
kafka,and put the notification config xml
The topic info:
<ListTopicsResponse
xmlns="https://sns.amazonaws.com/doc/2010-03-31/">
<ListTopicsResult>
<Topics>
<member>
<User>sr</User>
<Name>kafka</Name>
<EndPoint>
<EndpointAddress>kafka://192.168.3.250:9092
</EndpointAddress>
<EndpointArgs>kafka-ack-level=broker&push-endpoint=kafka://
192.168.3.250:9092</EndpointArgs>
<EndpointTopic>kafka</EndpointTopic>
</EndPoint>
<TopicArn>arn:aws:sns:default::kafka</TopicArn>
</member>
<member>
<User>sr</User>
<Name>kafka_kafka</Name>
<EndPoint>
<EndpointAddress>kafka://192.168.3.250:9092
</EndpointAddress>
<EndpointArgs>kafka-ack-level=broker&push-endpoint=kafka://
192.168.3.250:9092</EndpointArgs>
<EndpointTopic>kafka</EndpointTopic>
</EndPoint>
<TopicArn>arn:aws:sns:default::kafka</TopicArn>
</member>
<member>
<User>sr</User>
<Name>webno</Name>
<EndPoint>
<EndpointAddress>http://192.168.1.114:8080/s3/sn
</EndpointAddress>
<EndpointArgs>push-endpoint=
http://192.168.1.114:8080/s3/sn</EndpointArgs>
<EndpointTopic>webno</EndpointTopic>
</EndPoint>
<TopicArn>arn:aws:sns:default::webno</TopicArn>
</member>
</Topics>
</ListTopicsResult>
<ResponseMetadata>
<RequestId>c4b84c5b-1e88-4f16-9863-7f68872d91a4.744394.135</RequestId>
</ResponseMetadata>
</ListTopicsResponse>
and the put notification body :
<NotificationConfiguration
xmlns="http://s3.amazonaws.com/doc/2006-03-01/">
<TopicConfiguration> <Id>kafka</Id>
<Topic>arn:aws:sns:default::kafka</Topic> </TopicConfiguration>
</NotificationConfiguration>
The web notification works fine ,but when I use the kafka(version 1.0 jdk
1.8)
I got the debug info :
020-03-11 12:46:38.612 7fd81eeb1700 20 get_system_obj_state: s->obj_tag
was set empty
2020-03-11 12:46:38.612 7fd81eeb1700 10 cache get:
name=default.rgw.log++pubsub.user.sr.bucket.osstest/c4b84c5b-1e88-4f16-9863-7f68872d91a4.14175.1
: hit (requested=0x1, cached=0x17)
2020-03-11 12:46:38.612 7fd81eeb1700 20 notification: 'kafka' on topic:
'kafka' and bucket: 'osstest' (unique topic: 'kafka_kafka') apply
to event
of type: 's3:ObjectCreated:Put'
2020-03-11 12:46:38.612 7fd81eeb1700 1 ERROR: failed to create push
endpoint: kafka://192.168.3.250:9092 due to: pubsub endpoint
configuration error: unknown schema in: kafka://192.168.3.250:9092
2020-03-11 12:46:38.612 7fd81eeb1700 5 req 126 0.186s s3:put_obj WARNING:
publishing notification failed, with error: -22
2020-03-11 12:46:38.612 7fd81eeb1700 2
_______________________________________________
ceph-users mailing list -- ceph-users(a)ceph.io
To unsubscribe send an email to ceph-users-leave(a)ceph.io