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

[ https://issues.apache.org/jira/browse/KAFKA-4674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317809#comment-16317809 ] Andrey Falko commented on KAFKA-4674: - I just reproduced this on a 5 node test cluster by gradually

[jira] [Commented] (KAFKA-6396) Possibly kafka-connect converter should be able to stop processing chain

[ https://issues.apache.org/jira/browse/KAFKA-6396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317752#comment-16317752 ] Ewen Cheslack-Postava commented on KAFKA-6396: -- If I'm understanding your request properly,

[jira] [Commented] (KAFKA-4686) Null Message payload is shutting down broker

[ https://issues.apache.org/jira/browse/KAFKA-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317654#comment-16317654 ] Ewen Cheslack-Postava commented on KAFKA-4686: -- [~ijuma] This has been marked critical, but

[jira] [Updated] (KAFKA-6403) Why kafka sync send message with 10 seconds delay

[ https://issues.apache.org/jira/browse/KAFKA-6403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6403: - Fix Version/s: (was: 1.0.0) [~change] Since you've only provided some

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code} RestServer.httpRequest(reconfigUrl,

[jira] [Commented] (KAFKA-6384) TransactionsTest#testFencingOnSendOffsets sometimes fails with ProducerFencedException

[ https://issues.apache.org/jira/browse/KAFKA-6384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317566#comment-16317566 ] Ted Yu commented on KAFKA-6384: --- Haven't seen this failure for a while. >

[jira] [Commented] (KAFKA-6096) Add concurrent tests to exercise all paths in group/transaction managers

[ https://issues.apache.org/jira/browse/KAFKA-6096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317394#comment-16317394 ] ASF GitHub Bot commented on KAFKA-6096: --- hachikuji closed pull request #4122: KAFKA-6096: Add

[jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317346#comment-16317346 ] Joerg Heinicke commented on KAFKA-6366: --- Sorry for the delay. Even though I planned to at least try

[jira] [Commented] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change

[ https://issues.apache.org/jira/browse/KAFKA-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317333#comment-16317333 ] Randall Hauch commented on KAFKA-5505: -- We'll likely change/evolve Connect's rebalance subprotocol to

[jira] [Commented] (KAFKA-6433) Connect distributed workers should fail if their config is "incompatible" with leader's

[ https://issues.apache.org/jira/browse/KAFKA-6433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317329#comment-16317329 ] Randall Hauch commented on KAFKA-6433: -- KAFKA-5505 will likely be implemented as a change/evolution

[jira] [Updated] (KAFKA-6433) Connect distributed workers should fail if their config is "incompatible" with leader's

[ https://issues.apache.org/jira/browse/KAFKA-6433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6433: - Labels: needs-kip (was: ) > Connect distributed workers should fail if their config is

[jira] [Commented] (KAFKA-6433) Connect distributed workers should fail if their config is "incompatible" with leader's

[ https://issues.apache.org/jira/browse/KAFKA-6433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317325#comment-16317325 ] Randall Hauch commented on KAFKA-6433: -- Incidentally, it would not help to change what Connect stores

[jira] [Created] (KAFKA-6433) Connect distributed workers should fail if their config is "incompatible" with leader's

Randall Hauch created KAFKA-6433: Summary: Connect distributed workers should fail if their config is "incompatible" with leader's Key: KAFKA-6433 URL: https://issues.apache.org/jira/browse/KAFKA-6433

[jira] [Updated] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joerg Heinicke updated KAFKA-6366: -- Attachment: ConverterProcessor_DEBUG.zip > StackOverflowError in

[jira] [Commented] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317292#comment-16317292 ] ASF GitHub Bot commented on KAFKA-6422: --- hachikuji closed pull request #4387: KAFKA-6422 Mirror

[jira] [Commented] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly

[ https://issues.apache.org/jira/browse/KAFKA-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317240#comment-16317240 ] Guozhang Wang commented on KAFKA-6398: -- [~bja...@isi.nc] I can reproduce the issue you mentioned, and

[jira] [Updated] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly

[ https://issues.apache.org/jira/browse/KAFKA-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6398: - Description: For any operator that generates a KTable, its {{valueGetterSupplier}} has three

[jira] [Updated] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly

[ https://issues.apache.org/jira/browse/KAFKA-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6398: - Description: For any operator that generates a KTable, its {{valueGetterSupplier}} has three

[jira] [Updated] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly

[ https://issues.apache.org/jira/browse/KAFKA-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6398: - Priority: Critical (was: Major) > Non-aggregation KTable generation operator does not construct

[jira] [Updated] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly

[ https://issues.apache.org/jira/browse/KAFKA-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6398: - Summary: Non-aggregation KTable generation operator does not construct value getter correctly

[jira] [Resolved] (KAFKA-6428) Fail builds on findbugs warnings

[ https://issues.apache.org/jira/browse/KAFKA-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6428. -- Resolution: Invalid Seems it was already setup to report & fail, the reporting

[jira] [Commented] (KAFKA-6428) Fail builds on findbugs warnings

[ https://issues.apache.org/jira/browse/KAFKA-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317170#comment-16317170 ] ASF GitHub Bot commented on KAFKA-6428: --- ewencp closed pull request #4398: KAFKA-6428: Generate

[jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317097#comment-16317097 ] ASF GitHub Bot commented on KAFKA-3625: --- mjsax opened a new pull request #4402: KAFKA-3625: Add

[jira] [Updated] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3625: --- Description: The KStreamTestDriver and related fixtures defined in

[jira] [Commented] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16316912#comment-16316912 ] ASF GitHub Bot commented on KAFKA-6363: --- guozhangwang closed pull request #4371: KAFKA-6363: Use

[jira] [Updated] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should be accept raw text

[ https://issues.apache.org/jira/browse/KAFKA-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6424: - Labels: newbie unit-test (was: ) > QueryableStateIntegrationTest#queryOnRebalance should be

[jira] [Updated] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should be accept raw text

[ https://issues.apache.org/jira/browse/KAFKA-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6424: - Component/s: streams > QueryableStateIntegrationTest#queryOnRebalance should be accept raw text >

[jira] [Updated] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6412: -- Attachment: 6412-jmh.v1.txt > Improve synchronization in CachingKeyValueStore methods >

[jira] [Comment Edited] (KAFKA-6387) Worker's producer and consumer configs should inherit from worker configs

[ https://issues.apache.org/jira/browse/KAFKA-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16316820#comment-16316820 ] Randall Hauch edited comment on KAFKA-6387 at 1/8/18 7:25 PM: -- Created

[jira] [Resolved] (KAFKA-6387) Worker's producer and consumer configs should inherit from worker configs

[ https://issues.apache.org/jira/browse/KAFKA-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-6387. -- Resolution: Won't Fix Because of the inability to maintain backward compatibility of the

[jira] [Commented] (KAFKA-6387) Worker's producer and consumer configs should inherit from worker configs

[ https://issues.apache.org/jira/browse/KAFKA-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16316820#comment-16316820 ] Randall Hauch commented on KAFKA-6387: -- There are a number of cases where this behavior might

[jira] [Commented] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16316749#comment-16316749 ] James Cheng commented on KAFKA-6422: I have no ability to merge PRs, but the change looks good to me.

[jira] [Commented] (KAFKA-6369) General wildcard support for ACL's in kafka

[ https://issues.apache.org/jira/browse/KAFKA-6369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16316649#comment-16316649 ] Luiz Picanço commented on KAFKA-6369: - Seens related to KAFKA-5713 > General wildcard support for

[jira] [Commented] (KAFKA-3039) Temporary loss of leader resulted in log being completely truncated

[ https://issues.apache.org/jira/browse/KAFKA-3039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16316265#comment-16316265 ] Vincent Da commented on KAFKA-3039: --- we have also experienced this on a kafka server for many

[jira] [Resolved] (KAFKA-4315) Kafka Connect documentation problems

[ https://issues.apache.org/jira/browse/KAFKA-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki resolved KAFKA-4315. --- Resolution: Done I do not care anymore about this matter. > Kafka

[jira] [Closed] (KAFKA-4315) Kafka Connect documentation problems

[ https://issues.apache.org/jira/browse/KAFKA-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-4315. - > Kafka Connect documentation problems >

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

[ https://issues.apache.org/jira/browse/KAFKA-4908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-4908. - > consumer.properties logging warnings >

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

[ https://issues.apache.org/jira/browse/KAFKA-4908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki resolved KAFKA-4908. --- Resolution: Done Not an issue for me anymore. > consumer.properties

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16316179#comment-16316179 ] Seweryn Habdank-Wojewodzki commented on KAFKA-6260: --- Short question. When will those