[GitHub] kafka pull request #2048: Pluggable verifiable clients

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2048 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Re: [VOTE] KIP-122: Add Reset Consumer Group Offsets tooling

Thanks for the KIP! +1 (non-binding) On Tue, Mar 21, 2017 at 6:24 PM, Becket Qin wrote: > +1 > > Thanks for the KIP. The tool is very useful. > > On Tue, Mar 21, 2017 at 4:46 PM, Jason Gustafson > wrote: > > > +1 This looks super useful! Might be

Build failed in Jenkins: kafka-0.10.2-jdk7 #108

See Changes: [wangguoz] MINOR: updated incorrect JavaDocs for joins [wangguoz] MINOR: improve hanging ResetIntegrationTest -- [...truncated 616.85 KB...]

[jira] [Commented] (KAFKA-4848) Stream thread getting into deadlock state while trying to get rocksdb lock in retryWithBackoff

[ https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935744#comment-15935744 ] Sachin Mittal commented on KAFKA-4848: -- [~guozhang] We ran only once instance of streams application

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

See Changes: [wangguoz] MINOR: remove unused log field from KStreamTransformValuesProcessor [wangguoz] MINOR: updated incorrect JavaDocs for joins [me] KAFKA-4924: Fix Kafka Connect API findbugs warnings

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935739#comment-15935739 ] ASF GitHub Bot commented on KAFKA-4890: --- Github user guozhangwang closed the pull request at:

[GitHub] kafka pull request #2681: KAFKA-4890: Improve log4j for debugging [WIP]

Github user guozhangwang closed the pull request at: https://github.com/apache/kafka/pull/2681 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935729#comment-15935729 ] Guozhang Wang commented on KAFKA-4890: -- [~yunolgun] Thanks for the updates. I tried to reproduce the

[jira] [Commented] (KAFKA-4870) A question about broker down , the server is doing partition master election,the client producer may send msg fail . How the producer deal with the situation ??

[ https://issues.apache.org/jira/browse/KAFKA-4870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935727#comment-15935727 ] zhaoziyan commented on KAFKA-4870: -- thanks > A question about broker down , the server is doing

[jira] [Commented] (KAFKA-4919) Streams job fails with InvalidStateStoreException: Store is currently closed

[ https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935711#comment-15935711 ] Elias Levy commented on KAFKA-4919: --- I believe I found the issue. I am closing the store when my

[jira] [Commented] (KAFKA-4848) Stream thread getting into deadlock state while trying to get rocksdb lock in retryWithBackoff

[ https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935696#comment-15935696 ] Guozhang Wang commented on KAFKA-4848: -- [~sjmittal] Could I ask you a follow-up question: are these

[jira] [Commented] (KAFKA-4912) Add check for topic name length

[ https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935694#comment-15935694 ] Sharad commented on KAFKA-4912: --- [~mjsax] Topic name lengths are being checked in Topic.scala and

[GitHub] kafka pull request #2630: MINOR: improve hanging ResetIntegrationTest

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2630 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #2718: MINOR: log start and end offsets for state store r...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2718 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-4919) Streams job fails with InvalidStateStoreException: Store is currently closed

[ https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935663#comment-15935663 ] Guozhang Wang commented on KAFKA-4919: -- [~damianguy] Could you take a look? > Streams job fails with

Jenkins build is back to normal : kafka-trunk-jdk8 #1364

See

[jira] [Resolved] (KAFKA-4779) Failure in kafka/tests/kafkatest/tests/core/security_rolling_upgrade_test.py

[ https://issues.apache.org/jira/browse/KAFKA-4779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4779. Resolution: Fixed > Failure in kafka/tests/kafkatest/tests/core/security_rolling_upgrade_test.py >

Re: [VOTE] KIP-122: Add Reset Consumer Group Offsets tooling

+1 Thanks for the KIP. The tool is very useful. On Tue, Mar 21, 2017 at 4:46 PM, Jason Gustafson wrote: > +1 This looks super useful! Might be worth mentioning somewhere > compatibility with the old consumer. It looks like offsets in zk are not > covered, which seems fine,

[jira] [Commented] (KAFKA-4816) Message format changes for idempotent/transactional producer

[ https://issues.apache.org/jira/browse/KAFKA-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935601#comment-15935601 ] Apurva Mehta commented on KAFKA-4816: - I compiled the perf numbers for this patch, results available

[GitHub] kafka pull request #2721: Minor: Adding example to SMT documentation

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/2721 Minor: Adding example to SMT documentation You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka improve_smt_docs Alternatively you

[jira] [Resolved] (KAFKA-4917) Our built-in file connector can't work with our built-in SMT

[ https://issues.apache.org/jira/browse/KAFKA-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-4917. - Resolution: Won't Fix Hoist is fine :) > Our built-in file connector can't work with our

Re: [VOTE] KIP-82 Add Record Headers

Thanks for the KIP! +1 (binding) from me. Just one nit: can we change `Headers.header(key)` to be `Headers.lastHeader(key)`? It's not a deal-breaker, but I think it's better to let the name reflect the actual behavior as clearly as possible. -Jason On Wed, Feb 15, 2017 at 6:10 AM, Jeroen van

Re: [DISCUSS] KIP-129: Kafka Streams Exactly-Once Semantics

To add to this discussion, I do think we should think about this in increments. We do a full recovery today and the EOS proposal will not make this any worse. Using store snapshot is a good option to avoid store recovery in the future but as Eno points out, all pluggable stores would need to have

[jira] [Commented] (KAFKA-4924) Fix findbugs warnings in Kafka-Connect-API

[ https://issues.apache.org/jira/browse/KAFKA-4924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935559#comment-15935559 ] ASF GitHub Bot commented on KAFKA-4924: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-4924) Fix findbugs warnings in Kafka-Connect-API

[ https://issues.apache.org/jira/browse/KAFKA-4924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4924. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request

[GitHub] kafka pull request #2715: KAFKA-4924: Fix Kafka Connect API findbugs warning...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2715 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Re: [VOTE] KIP-122: Add Reset Consumer Group Offsets tooling

+1 This looks super useful! Might be worth mentioning somewhere compatibility with the old consumer. It looks like offsets in zk are not covered, which seems fine, but probably should be explicitly noted. Maybe you can also add a note saying that the tool can be used for old consumers which have

Re: [DISCUSS] KIP-129: Kafka Streams Exactly-Once Semantics

Thanks for your feedback Eno. For now, I still think that the KIP itself does not need to talk about this in more detail, because we apply the same strategy for EoS as for non-EoS (as of 0.10.2). Thus, in case of a clean shutdown, we write the checkpoint file for a store and thus know we can

Re: [DISCUSS] KIP-120: Cleanup Kafka Streams builder API

@Guozhang: I recognized that you want to have `Topology` in the name. But it seems that more people preferred to not have it (Jay, Ram, Michael [?], myself). @Michael: You seemed to agree with Jay about not exposing the `Topology` concept in our main entry class (ie, current KStreamBuilder),

[jira] [Updated] (KAFKA-4929) Transformation Key/Value type references should be to class name(), not canonicalName()

[ https://issues.apache.org/jira/browse/KAFKA-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4929: - Component/s: KafkaConnect > Transformation Key/Value type references should be to class name(),

[GitHub] kafka pull request #2670: MINOR: updated incorrect JavaDocs for joins

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2670 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #2717: MINOR: remove unused log field from KStreamTransfo...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2717 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Updated] (KAFKA-4863) Querying window store may return unwanted keys

[ https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4863: - Fix Version/s: 0.10.2.1 > Querying window store may return unwanted keys >

[jira] [Commented] (KAFKA-4863) Querying window store may return unwanted keys

[ https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935519#comment-15935519 ] ASF GitHub Bot commented on KAFKA-4863: --- Github user asfgit closed the pull request at:

[GitHub] kafka pull request #2713: KAFKA-4863: [Follow Up] Querying window store may ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2713 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Updated] (KAFKA-4863) Querying window store may return unwanted keys

[ https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4863: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch

[jira] [Updated] (KAFKA-4929) Transformation Key/Value type references should be to class name(), not canonicalName()

[ https://issues.apache.org/jira/browse/KAFKA-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bruce szalwinski updated KAFKA-4929: Status: Patch Available (was: Open) > Transformation Key/Value type references should be

[jira] [Commented] (KAFKA-2273) KIP-54: Add rebalance with a minimal number of reassignments to server-defined strategy list

[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935450#comment-15935450 ] Allen Wang commented on KAFKA-2273: --- Does the current implementation have any dependency on Kafka 0.10

Re: Re: [DISCUSS] KIP-120: Cleanup Kafka Streams builder API

Just to clarify, I did want to have the term `Topology` as part of the class name, for the reasons above. I'm not too worried about to be consistent with the previous names, but I feel the `XXTopologyBuilder` is better than `XXStreamsBuilder` since it's build() function returns a Topology object.

[jira] [Commented] (KAFKA-4929) Transformation Key/Value type references should be to class name(), not canonicalName()

[ https://issues.apache.org/jira/browse/KAFKA-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935387#comment-15935387 ] ASF GitHub Bot commented on KAFKA-4929: --- GitHub user bruce-szalwinski opened a pull request:

[GitHub] kafka pull request #2720: KAFKA-4929: Transformation Key/Value type referenc...

GitHub user bruce-szalwinski opened a pull request: https://github.com/apache/kafka/pull/2720 KAFKA-4929: Transformation Key/Value type references should be to class name(), not canonicalName() You can merge this pull request into a Git repository by running: $ git pull

Re: [VOTE] KIP-124: Request rate quotas

+1. Thanks! On Tue, Mar 21, 2017 at 2:00 PM, Becket Qin wrote: > +1 > > Thanks for driving through this, Rajini :) > > > > On Tue, Mar 21, 2017 at 9:49 AM, Roger Hoover > wrote: > > > Rajini, > > > > This is great. Thank you. +1 (non-binding) > >

[jira] [Created] (KAFKA-4929) Transformation Key/Value type references should be to class name(), not canonicalName()

bruce szalwinski created KAFKA-4929: --- Summary: Transformation Key/Value type references should be to class name(), not canonicalName() Key: KAFKA-4929 URL: https://issues.apache.org/jira/browse/KAFKA-4929

[jira] [Comment Edited] (KAFKA-4808) send of null key to a compacted topic should throw error back to user

[ https://issues.apache.org/jira/browse/KAFKA-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935327#comment-15935327 ] Mayuresh Gharat edited comment on KAFKA-4808 at 3/21/17 9:00 PM: - [~ijuma]

Re: [VOTE] KIP-124: Request rate quotas

+1 Thanks for driving through this, Rajini :) On Tue, Mar 21, 2017 at 9:49 AM, Roger Hoover wrote: > Rajini, > > This is great. Thank you. +1 (non-binding) > > Roger > > On Tue, Mar 21, 2017 at 8:55 AM, Ismael Juma wrote: > > > Rajini, > > > >

[jira] [Commented] (KAFKA-4808) send of null key to a compacted topic should throw error back to user

[ https://issues.apache.org/jira/browse/KAFKA-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935327#comment-15935327 ] Mayuresh Gharat commented on KAFKA-4808: [~ijuma] Please find the KIP here :

[jira] [Commented] (KAFKA-4908) consumer.properties logging warnings

[ https://issues.apache.org/jira/browse/KAFKA-4908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935288#comment-15935288 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4908: --- So even more. Deprecated configs

[jira] [Commented] (KAFKA-4870) A question about broker down , the server is doing partition master election,the client producer may send msg fail . How the producer deal with the situation ??

[ https://issues.apache.org/jira/browse/KAFKA-4870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935281#comment-15935281 ] Colin P. McCabe commented on KAFKA-4870: This seems like a question, rather than a bug. Did you

Re: Features ideas - need feedback: message deletion and consumer improvements

On Wed, Mar 8, 2017, at 17:28, Maarek, Stephane wrote: > Hi, > > Two ideas that I would like to get feedback on before putting KIPs > together. > > 1) Ability to have the kafka client consumer “skip” data that can’t be > de-serialized. it would be a consumer config such as >

[jira] [Commented] (KAFKA-4919) Streams job fails with InvalidStateStoreException: Store is currently closed

[ https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935252#comment-15935252 ] Elias Levy commented on KAFKA-4919: --- The issue appears to be that a {{RocksDBStore}} segment of a

[jira] [Comment Edited] (KAFKA-4878) Kafka Connect does not log connector configuration errors

[ https://issues.apache.org/jira/browse/KAFKA-4878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935249#comment-15935249 ] Armin Braun edited comment on KAFKA-4878 at 3/21/17 8:23 PM: - [~gwenshap] Np,

[jira] [Commented] (KAFKA-4878) Kafka Connect does not log connector configuration errors

[ https://issues.apache.org/jira/browse/KAFKA-4878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935249#comment-15935249 ] Armin Braun commented on KAFKA-4878: [~gwenshap] debugged this on the weekend and was going to put in

[jira] [Commented] (KAFKA-4916) Add streams tests with brokers failing

[ https://issues.apache.org/jira/browse/KAFKA-4916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935102#comment-15935102 ] ASF GitHub Bot commented on KAFKA-4916: --- GitHub user enothereska opened a pull request:

[GitHub] kafka pull request #2719: KAFKA-4916: test streams with brokers failing [WiP...

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2719 KAFKA-4916: test streams with brokers failing [WiP] You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Hey Jun, Thanks for the explanation. Please see below my thoughts. 10. I see. So you are concerned with the potential implementation complexity which I wasn't aware of. I think it is OK not to do log cleaning on the .move log since there can be only one such log in each directory. I have updated

[jira] [Comment Edited] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers

in the logs. See attached broker log file. Please let me know if you need more log files and/or details. [Update 20170321] Just wanted to clarify that this is on Kafka 0.10.0.1. We thought we would see this fixed after upgrading to Kafka 0.10.1.1, but that one is experiencing the same issues

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Hi, Dong, 10. I was mainly concerned about the additional complexity needed to support log cleaning in the .move log. For example, LogToClean is keyed off TopicPartition. To be able to support cleaning different instances of the same partition, we need additional logic. I am not how much

[GitHub] kafka pull request #2718: MINOR: log start and end offsets for state store r...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2718 MINOR: log start and end offsets for state store restoration Debug loggin of the start and end offsets used during state store restoration You can merge this pull request into a Git repository by

Re: [VOTE] KIP-124: Request rate quotas

Rajini, This is great. Thank you. +1 (non-binding) Roger On Tue, Mar 21, 2017 at 8:55 AM, Ismael Juma wrote: > Rajini, > > Thanks for the proposal and for addressing the (sometimes contradictory) > feedback. :) +1 (binding) from me. > > Ismael > > On Mon, Mar 20, 2017 at

[jira] [Commented] (KAFKA-4878) Kafka Connect does not log connector configuration errors

[ https://issues.apache.org/jira/browse/KAFKA-4878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934854#comment-15934854 ] Gwen Shapira commented on KAFKA-4878: - [~original-brownbear] - Thank you. Let me know if you need help

[GitHub] kafka pull request #2717: MINOR: remove unused log field from KStreamTransfo...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2717 MINOR: remove unused log field from KStreamTransformValuesProcessor remove unused log field from KStreamTransformValuesProcessor You can merge this pull request into a Git repository by running:

Re: [VOTE] KIP-124: Request rate quotas

Rajini, Thanks for the proposal and for addressing the (sometimes contradictory) feedback. :) +1 (binding) from me. Ismael On Mon, Mar 20, 2017 at 2:47 PM, Rajini Sivaram wrote: > I would like to initiate the voting process for KIP-124: > >

[jira] [Commented] (KAFKA-4927) KStreamsTestDriver fails with NPE when KStream.to() sinks are used

[ https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934793#comment-15934793 ] ASF GitHub Bot commented on KAFKA-4927: --- GitHub user wimvanleuven opened a pull request:

[GitHub] kafka pull request #2716: KAFKA-4927 : KStreamsTestDriver fails with NPE whe...

GitHub user wimvanleuven opened a pull request: https://github.com/apache/kafka/pull/2716 KAFKA-4927 : KStreamsTestDriver fails with NPE when KStream.to() sinks are used a KStream.to() sink is also a topic ... so the KStreamTestDriver to fetch it when required You can merge

[jira] [Updated] (KAFKA-4927) KStreamsTestDriver fails with NPE when KStream.to() sinks are used

[ https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wim Van Leuven updated KAFKA-4927: -- Summary: KStreamsTestDriver fails with NPE when KStream.to() sinks are used (was:

[jira] [Updated] (KAFKA-4927) KStreamsTestDriver fails with NPE when Topic sinks are used

[ https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wim Van Leuven updated KAFKA-4927: -- Summary: KStreamsTestDriver fails with NPE when Topic sinks are used (was: KStreamsTestDriver

Re: [VOTE] KIP-124: Request rate quotas

Hi, Rajini, Thanks for the proposal. +1 from me. Jun On Mon, Mar 20, 2017 at 7:47 AM, Rajini Sivaram wrote: > I would like to initiate the voting process for KIP-124: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 124+-+Request+rate+quotas > > The KIP

[jira] [Updated] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source

[ https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-4791: Affects Version/s: 0.10.2.0 > Kafka Streams - unable to add state stores when using wildcard topics

[jira] [Created] (KAFKA-4928) Add integration test for DumpLogSegments

Ismael Juma created KAFKA-4928: -- Summary: Add integration test for DumpLogSegments Key: KAFKA-4928 URL: https://issues.apache.org/jira/browse/KAFKA-4928 Project: Kafka Issue Type: Test

[DISCUSS] KAFKA-4911 Add ProducerRecord to ProducerInterceptor#onAcknowledgement

Greetings all, Please correct me if this is not the right place to discuss this. I filed a jira about this but I figured the mailing list might encourage better collaboration. I'd like to propose adding the ProducerRecord field to the onAcknowledgement callback in the ProducerInterceptor

[jira] [Created] (KAFKA-4927) KStreamsTestDriver fails with NullPointerException when Topic sinks are used

Wim Van Leuven created KAFKA-4927: - Summary: KStreamsTestDriver fails with NullPointerException when Topic sinks are used Key: KAFKA-4927 URL: https://issues.apache.org/jira/browse/KAFKA-4927

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

See Changes: [ismael] MINOR: Fix zookeeper-security-migration documentation example [ismael] KAFKA-4594; Annotate integration tests and provide gradle build targets --

Jenkins build is back to normal : kafka-trunk-jdk7 #2026

See

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

See Changes: [wangguoz] KAFKA-4848: Fix retryWithBackoff deadlock issue -- [...truncated 1.60 MB...]

[GitHub] kafka pull request #2695: KAFKA-4594: Annotate integration tests and provide...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2695 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #2714: Fix ZKSec Migrate example

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2714 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Build failed in Jenkins: kafka-trunk-jdk7 #2025

See Changes: [wangguoz] KAFKA-4848: Fix retryWithBackoff deadlock issue -- [...truncated 163.82 KB...] kafka.producer.ProducerTest > testSendNullMessage STARTED