Re: Experimenting with Kafka and OpenSSL

Thanks Jaikiran. This is is useful. However, as you point out, the ciphers are an important factor. It would be good to ensure that the encryption strength is comparable to make it fair. The first step could be to output the ciphers used by Java 9 and OpenSSL by default. Ismael On 11 Nov 2017 7:3

Re: Listeners and reference/docs

Awesome, makes perfect sense thank you! On 11/10/2017 07:28 PM, Kaufman Ng wrote: I think "CLIENT" is just an example. The default for listener.security.protocol.map doesn't have it. If you look at the KIP link in my email there's a more complete example: listener.security.protocol.map=CLIENT:

Kafka Connect JDBC Array Type

Hey All, I'm using the JDBC sink to materialise a kafka topic in a postgres table. The records in the topic are avro messages. I'm running into this problem because one of the fields in the messages is an array: org.apache.kafka.connect.errors.ConnectException: null (ARRAY) type doesn't have a ma

Re: Questions about kafka-consumer-groups output

Hi Michael, Java based Kafka consumers can consume messages in two ways: - simple: by manually assigning partitions to a consumer to consume from - consumer group: a group of consumers consume messages in a coordinated fashion (by subscribing to topics and having partitions automatically assigne

Kafka Custom Authentication & Authorization

Hi All, To Authenticate & Authorize the producer and consumers, I want to integrate with third party Entitlement manager. Is there reference implementation ? Any link for doc or comments I appreciate. Regards Bhanu

delete topic command won't delete the ACLs znode for the topic

Is it a bug? The delete topic command won’t delete the ACLs znode for the deleted topic. Thanks, Mike