Build failed in Jenkins: kafka-trunk-jdk11 #770

See Changes: [wangguoz] KAFKA-8824: bypass value serde on null (#7235) -- [...truncated 2.64 MB...] org.apache.kafka.connect.json.JsonConverterTest > timeToConnectOptiona

Build failed in Jenkins: kafka-trunk-jdk8 #3866

See Changes: [wangguoz] KAFKA-8824: bypass value serde on null (#7235) -- [...truncated 2.59 MB...] org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldForw

Re: [DISCUSS] KIP-486 Support for pluggable KeyStore and TrustStore

Hi Harsha Any response on my question? I feel this KIP is worth accommodating. Your help is much appreciated. Thanks Maulin On Tue, Aug 20, 2019 at 11:52 PM Maulin Vasavada wrote: > Hi Harsha > > I've examined the SPIFFE provider more and have one question - > > If SPIFFE didn't have a need to

Re: [VOTE] KIP-352: Distinguish URPs caused by reassignment

+1 (binding) Thanks Jason. This is super useful. --Vahid On Tue, Aug 20, 2019 at 10:55 AM Jason Gustafson wrote: > Hi All, > > I'd like to start a vote on KIP-352, which is a follow-up to KIP-455 to fix > a long-known shortcoming of URP reporting and to improve reassignment > monitoring: > > h

Re: [VOTE] KIP-352: Distinguish URPs caused by reassignment

+1 (binding) Thanks, Harsha On Wed, Aug 21, 2019 at 4:23 PM, Robert Barrett < bob.barr...@confluent.io > wrote: > > > > +1 (non-binding) > > > > This will be great to have, thanks Jason! > > > > On Wed, Aug 21, 2019 at 4:29 AM Manikumar < manikumar. reddy@ gmail. com ( > manikumar.re.

Build failed in Jenkins: kafka-trunk-jdk8 #3865

See Changes: [jason] KAFKA-8325; Remove batch from in-flight requests on MESSAGE_TOO_LARGE -- [...truncated 2.59 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [DISCUSS] KIP-500: Replace ZooKeeper with a Self-Managed Metadata Quorum

On Wed, Aug 21, 2019, at 19:48, Ron Dagostino wrote: > Thanks, Colin. The changes you made to the KIP related to the bridge > release help make it clearer. I still have some confusion about the phrase > "The rolling upgrade from the bridge release will take several steps." > This made me think yo

[jira] [Created] (KAFKA-8826) Improve logging for SSL ciphers and principals

Colin P. McCabe created KAFKA-8826: -- Summary: Improve logging for SSL ciphers and principals Key: KAFKA-8826 URL: https://issues.apache.org/jira/browse/KAFKA-8826 Project: Kafka Issue Type:

Re: mixing assign and subscribe for a group

Shailesh, the users list may be a better place for this question. Assign() and subscribe() cannot be used on the same Consumer. Moreover, an assign()'d Consumer is not really a member of a group. You should use AdminClient.listConsumerGroupOffsets() for this purpose. Ryanne On Thu, Aug 22, 2019

Re: [VOTE] KIP-444: Refactor and Augment Metrics for Kafka Streams

+1 (binding) -Bill On Thu, Aug 22, 2019 at 10:55 AM John Roesler wrote: > Hi Guozhang, thanks for cleaning this up. > > I'm +1 (non-binding) > > Thanks, > -John > > On Thu, Aug 22, 2019 at 2:26 AM Bruno Cadonna wrote: > > > Hi Guozhang, > > > > +1 (non-binding) > > > > Thank you for driving th

Re: ACL for group creation?

Hi Adam, Assuming you have a cluster where access to any groups is denied by default, you can allow a principal to only have access to one group. Something like the following: kafka-acls.sh --add --allow-principal User:CN=my-principal --operation Read --topic 'my-topic' --group 'my-group' With t

Re: [VOTE] KIP-444: Refactor and Augment Metrics for Kafka Streams

Hi Guozhang, thanks for cleaning this up. I'm +1 (non-binding) Thanks, -John On Thu, Aug 22, 2019 at 2:26 AM Bruno Cadonna wrote: > Hi Guozhang, > > +1 (non-binding) > > Thank you for driving this! > Bruno > > On Tue, Aug 20, 2019 at 8:29 PM Guozhang Wang wrote: > > > > Hello folks, > > > > I

Re: ACL for group creation?

I see the consumer group much like the username in relational database access credentials. We routinely use the consumer group name as the means of identifying the consumer for operational things, such as alerting based on consumer group lag, autoscaling based on lag, and tooling around manipulatin

mixing assign and subscribe for a group

Classification: Public Hi All, We have a kafka cluster where we are using consumer.subscribe() for a group id. We also are trying to write a simple monitoring tool running as a separate instance on a different host than the consumers for checking the consumer offsets and for that we have used

Build failed in Jenkins: kafka-trunk-jdk8 #3864

See Changes: [matthias] KIP-476: Add new getAdmin method to KafkaClientSupplier (#7162) -- [...truncated 6.26 MB...] kafka.api.PlaintextConsumerTest > testCoordinatorFail

Jenkins build is back to normal : kafka-2.3-jdk8 #93

See

Build failed in Jenkins: kafka-trunk-jdk11 #769

See Changes: [jason] KAFKA-8325; Remove batch from in-flight requests on MESSAGE_TOO_LARGE -- [...truncated 2.60 MB...] org.apache.kafka.connect.json.JsonConverterTest >

Re: [DISCUSS] KIP-511: Collect and Expose Client's Name and Version in the Brokers

Hi Satish, Thank you for your feedback! Please find my answers below. >> Did you consider taking version property by loading “kafka/kafka-version.properties” as a resource while java client is initialized? “kafka/kafka-version.properties” is shipped with kafka-clients jar. I wasn't aware of th

Re: [VOTE] KIP-444: Refactor and Augment Metrics for Kafka Streams

Hi Guozhang, +1 (non-binding) Thank you for driving this! Bruno On Tue, Aug 20, 2019 at 8:29 PM Guozhang Wang wrote: > > Hello folks, > > I'd like to start a voting thread the following KIP to improve the Kafka > Streams metrics mechanism to users. This includes 1) renaming changes in > the pub