[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 enab

[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 enab

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

See Changes: [wangguoz] KAFKA-4848: Fix retryWithBackoff deadlock issue -- [...truncated 1.60 MB...] org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTes

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

See

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 -- [.

[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 Project:

[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 interfa

[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

[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

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 proposes to add request proc

[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 f

[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 thi

[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&focusedCommentId=15934793#comment-15934793 ] ASF GitHub Bot commented on KAFKA-4927: --- GitHub user wimvanleuven opened a pull requ

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: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP

[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: KStreamsTestD

[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: $

[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&focusedCommentId=15934854#comment-15934854 ] Gwen Shapira commented on KAFKA-4878: - [~original-brownbear] - Thank you. Let me know

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 2:47 PM, Rajini Siva

[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 runn

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 additiona

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

eing any exceptions 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 experien

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

[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 KAFKA-4916-broker-bou

[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&focusedCommentId=15935102#comment-15935102 ] ASF GitHub Bot commented on KAFKA-4916: --- GitHub user enothereska opened a pull reque

[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&focusedCommentId=15935249#comment-15935249 ] Armin Braun commented on KAFKA-4878: [~gwenshap] debugged this on the weekend and was

[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&focusedCommentId=15935249#comment-15935249 ] Armin Braun edited comment on KAFKA-4878 at 3/21/17 8:23 PM: -

[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&focusedCommentId=15935252#comment-15935252 ] Elias Levy commented on KAFKA-4919: --- The issue appears to be that a {{RocksDBStore}} seg

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 > “ignore.deserializati

[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&focusedCommentId=15935281#comment-15935281 ] Colin P. McCabe commented on KAFKA-4870: This seems like a question, rather than a

[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&focusedCommentId=15935288#comment-15935288 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4908: --- So even more. Depre

[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&focusedCommentId=15935327#comment-15935327 ] Mayuresh Gharat commented on KAFKA-4808: [~ijuma] Please find the KIP here : htt

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, > > > > Thanks for the proposal and for addressing the

[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&focusedCommentId=15935327#comment-15935327 ] Mayuresh Gharat edited comment on KAFKA-4808 at 3/21/17 9:00 PM: ---

[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

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) > > > > Roger > > > > On Tue, Mar 21, 2017 at 8:55

[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 https

[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&focusedCommentId=15935387#comment-15935387 ] ASF GitHub Bot commented on KAFKA-4929: --- GitHub user bruce-szalwinski opened a pull

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-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&focusedCommentId=15935450#comment-15935450 ] Allen Wang commented on KAFKA-2273: --- Does the current implementation have any dependency

[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 to

[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 Available

[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 enab

[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&focusedCommentId=15935519#comment-15935519 ] ASF GitHub Bot commented on KAFKA-4863: --- Github user asfgit closed the pull request

[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 > ---

[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 enab

[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 enab

[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(), no

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), thu

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 reus

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 of

[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 enab

[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

[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&focusedCommentId=15935559#comment-15935559 ] ASF GitHub Bot commented on KAFKA-4924: --- Github user asfgit closed the pull request

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 t

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 Diss

[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 built-in

[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 c

[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&focusedCommentId=15935601#comment-15935601 ] Apurva Mehta commented on KAFKA-4816: - I compiled the perf numbers for this patch, res

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, but probably should b

[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 > -

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

See

[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&focusedCommentId=15935663#comment-15935663 ] Guozhang Wang commented on KAFKA-4919: -- [~damianguy] Could you take a look? > Stream

[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 enab

[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 enab

[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&focusedCommentId=15935694#comment-15935694 ] Sharad commented on KAFKA-4912: --- [~mjsax] Topic name lengths are being checked in Topic.scal

[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&focusedCommentId=15935696#comment-15935696 ] Guozhang Wang commented on KAFKA-4848: -- [~sjmittal] Could I ask you a follow-up quest

[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&focusedCommentId=15935711#comment-15935711 ] Elias Levy commented on KAFKA-4919: --- I believe I found the issue. I am closing the stor

[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&focusedCommentId=15935727#comment-15935727 ] zhaoziyan commented on KAFKA-4870: -- thanks > A question about broker down , the server

[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&focusedCommentId=15935729#comment-15935729 ] Guozhang Wang commented on KAFKA-4890: -- [~yunolgun] Thanks for the updates. I tried t

[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 i

[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&focusedCommentId=15935739#comment-15935739 ] ASF GitHub Bot commented on KAFKA-4890: --- Github user guozhangwang closed the pull re

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-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&focusedCommentId=15935744#comment-15935744 ] Sachin Mittal commented on KAFKA-4848: -- [~guozhang] We ran only once instance of stre

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...] org.apache.kafk

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 worth mentioning somewhere > > compatibility wi

[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 enab