[jira] [Commented] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds

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

[jira] [Commented] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

[ https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296290#comment-16296290 ] Richard Yu commented on KAFKA-6328: --- [~guozhang] I have the minor suspicion that global node groups

[jira] [Updated] (KAFKA-6311) Expose Kafka cluster ID in Connect REST API

[ https://issues.apache.org/jira/browse/KAFKA-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6311: - Fix Version/s: 1.1.0 > Expose Kafka cluster ID in Connect REST API >

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

Ted Yu created KAFKA-6384: - Summary: TransactionsTest#testFencingOnSendOffsets sometimes fails with ProducerFencedException Key: KAFKA-6384 URL: https://issues.apache.org/jira/browse/KAFKA-6384 Project:

[jira] [Comment Edited] (KAFKA-6375) Follower replicas can never catch up to be ISR due to creating ReplicaFetcherThread failed.

[ https://issues.apache.org/jira/browse/KAFKA-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296063#comment-16296063 ] Rong Tang edited comment on KAFKA-6375 at 12/19/17 2:47 AM: [~huxi_2b] The

[jira] [Comment Edited] (KAFKA-6375) Follower replicas can never catch up to be ISR due to creating ReplicaFetcherThread failed.

[ https://issues.apache.org/jira/browse/KAFKA-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296063#comment-16296063 ] Rong Tang edited comment on KAFKA-6375 at 12/19/17 2:45 AM: [~huxi_2b] The

[jira] [Commented] (KAFKA-6375) Follower replicas can never catch up to be ISR due to creating ReplicaFetcherThread failed.

[ https://issues.apache.org/jira/browse/KAFKA-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296048#comment-16296048 ] huxihx commented on KAFKA-6375: --- [~trjianjianjiao] LeaderAndIsr might not be impacted although replica fetch

[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=16295970#comment-16295970 ] Jason Gustafson commented on KAFKA-6366: [~joerg.heinicke] Thanks. Nothing weird that I can see

[jira] [Updated] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start

[ https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6383: --- Affects Version/s: 1.0.0 > StreamThread.shutdown doesn't clean up completely when called

[jira] [Updated] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start

[ https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6383: --- Component/s: streams > StreamThread.shutdown doesn't clean up completely when called before

[jira] [Created] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called beforeStreamThread.start

Rohan Desai created KAFKA-6383: -- Summary: StreamThread.shutdown doesn't clean up completely when called beforeStreamThread.start Key: KAFKA-6383 URL: https://issues.apache.org/jira/browse/KAFKA-6383

[jira] [Updated] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start

[ https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohan Desai updated KAFKA-6383: --- Summary: StreamThread.shutdown doesn't clean up completely when called before StreamThread.start

[jira] [Reopened] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds

[ https://issues.apache.org/jira/browse/KAFKA-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4263: Assignee: Matthias J. Sax (was: Damian Guy) Reopening this. Happened again:

[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=16295850#comment-16295850 ] Joerg Heinicke commented on KAFKA-6366: --- ConsumerConfig values: auto.offset.reset = earliest

[jira] [Updated] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public

[ https://issues.apache.org/jira/browse/KAFKA-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6382: --- Labels: kip (was: ) > Make ProducerConfig and ConsumerConfig constructors public >

[jira] [Comment Edited] (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=16295813#comment-16295813 ] Joerg Heinicke edited comment on KAFKA-6366 at 12/18/17 11:03 PM: -- Let me

[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=16295813#comment-16295813 ] Joerg Heinicke commented on KAFKA-6366: --- Let me try to provide you all the details required: Quite a

[jira] [Commented] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public

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

[jira] [Updated] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public

[ https://issues.apache.org/jira/browse/KAFKA-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6382: --- Description: Constructors of {{ProducerConfig}} and {{ConsumerConfig}} are not public atm.

[jira] [Created] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public

Matthias J. Sax created KAFKA-6382: -- Summary: Make ProducerConfig and ConsumerConfig constructors public Key: KAFKA-6382 URL: https://issues.apache.org/jira/browse/KAFKA-6382 Project: Kafka

[jira] [Created] (KAFKA-6381) Improve KafkaStreamsTest for localThreadMetadata

Matthias J. Sax created KAFKA-6381: -- Summary: Improve KafkaStreamsTest for localThreadMetadata Key: KAFKA-6381 URL: https://issues.apache.org/jira/browse/KAFKA-6381 Project: Kafka Issue

[jira] [Commented] (KAFKA-6265) GlobalKTable missing #queryableStoreName()

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

[jira] [Commented] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

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

[jira] [Comment Edited] (KAFKA-2359) New consumer - partitions auto assigned only on poll

[ https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295659#comment-16295659 ] Stu edited comment on KAFKA-2359 at 12/18/17 9:05 PM: -- Granted, I may be using Kafka

[jira] [Comment Edited] (KAFKA-2359) New consumer - partitions auto assigned only on poll

[ https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295659#comment-16295659 ] Stu edited comment on KAFKA-2359 at 12/18/17 9:05 PM: -- Granted, I may be using Kafka

[jira] [Commented] (KAFKA-2359) New consumer - partitions auto assigned only on poll

[ https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295659#comment-16295659 ] Stu commented on KAFKA-2359: Granted, I may be using Kafka in a place where another queue would be better,

[jira] [Commented] (KAFKA-5285) optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295649#comment-16295649 ] Guozhang Wang commented on KAFKA-5285: -- I'll let [~damianguy] to chime in more on this issue. Though

[jira] [Commented] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers

[ https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295599#comment-16295599 ] Jason Gustafson commented on KAFKA-6336: I tested using manual assignment on 0.10.2 and it seems

[jira] [Commented] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

[ https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295597#comment-16295597 ] Matthias J. Sax commented on KAFKA-6328: You can create as many branches in your own Kafka GitHub

[jira] [Commented] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

[ https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295558#comment-16295558 ] Richard Yu commented on KAFKA-6328: --- Sorry, I am currently operating on "one active PR" basis. Meaning I

[jira] [Resolved] (KAFKA-6258) SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data

[ https://issues.apache.org/jira/browse/KAFKA-6258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6258. Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Issue resolved by

[jira] [Assigned] (KAFKA-6331) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-6331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-6331: --- Assignee: Dong Lin > Transient failure in >

[jira] [Commented] (KAFKA-6258) SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data

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

[jira] [Commented] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295486#comment-16295486 ] Guozhang Wang commented on KAFKA-6376: -- Regarding 3), what I meant is that in user's own `process()`

[jira] [Resolved] (KAFKA-6373) Log end offset of input table changing during restore

[ https://issues.apache.org/jira/browse/KAFKA-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6373. Resolution: Duplicate Duplicate issue of KAFKA-6269 > Log end offset of input table changing

[jira] [Commented] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

[ https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295412#comment-16295412 ] Matthias J. Sax commented on KAFKA-6328: Thanks for the patch. Please assign the JIRA to yourself

[jira] [Commented] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately

[ https://issues.apache.org/jira/browse/KAFKA-6323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295406#comment-16295406 ] Matthias J. Sax commented on KAFKA-6323: It's a fair question. I personally like code that is as

[jira] [Commented] (KAFKA-6375) Follower replicas can never catch up to be ISR due to creating ReplicaFetcherThread failed.

[ https://issues.apache.org/jira/browse/KAFKA-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295400#comment-16295400 ] Rong Tang commented on KAFKA-6375: -- [~huxi_2b] The firewall on that Windows machine is : Domain networks

[jira] [Commented] (KAFKA-6353) Connector status shows FAILED but actually task is in RUNNING status

[ https://issues.apache.org/jira/browse/KAFKA-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295377#comment-16295377 ] Chen He commented on KAFKA-6353: Thank you, Mr. [~rhauch]. Just sent the email. Also some updates on

[jira] [Commented] (KAFKA-6353) Connector status shows FAILED but actually task is in RUNNING status

[ https://issues.apache.org/jira/browse/KAFKA-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295315#comment-16295315 ] Randall Hauch commented on KAFKA-6353: -- [~airbots], per https://kafka.apache.org/contributing please

[jira] [Commented] (KAFKA-6373) Log end offset of input table changing during restore

[ https://issues.apache.org/jira/browse/KAFKA-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295291#comment-16295291 ] Charles Crain commented on KAFKA-6373: -- Yep that looks like the same issue!! Feel free to close this

[jira] [Commented] (KAFKA-6287) Inconsistent protocol type for empty consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295281#comment-16295281 ] Ryan Leslie commented on KAFKA-6287: Thanks for reviewing. I agree that the protocol type shouldn't be

[jira] [Updated] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

[ https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-6328: -- Attachment: kafka-6328.diff Patch for excluding node groups > Exclude node groups belonging to global

[jira] [Updated] (KAFKA-6373) Log end offset of input table changing during restore

[ https://issues.apache.org/jira/browse/KAFKA-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-6373: --- Component/s: (was: clients) streams > Log end offset of input table changing

[jira] [Commented] (KAFKA-6373) Log end offset of input table changing during restore

[ https://issues.apache.org/jira/browse/KAFKA-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295019#comment-16295019 ] Bill Bejeck commented on KAFKA-6373: Hi Charles, Thanks for reporting this. It looks like you run

[jira] [Comment Edited] (KAFKA-6373) Log end offset of input table changing during restore

[ https://issues.apache.org/jira/browse/KAFKA-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294913#comment-16294913 ] Charles Crain edited comment on KAFKA-6373 at 12/18/17 12:40 PM: - As an

[jira] [Commented] (KAFKA-6373) Log end offset of input table changing during restore

[ https://issues.apache.org/jira/browse/KAFKA-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294913#comment-16294913 ] Charles Crain commented on KAFKA-6373: -- As an update, going back to the 0.11.0.2 client libraries

[jira] [Created] (KAFKA-6380) transient failure in MetricsTest.testMetrics

Manikumar created KAFKA-6380: Summary: transient failure in MetricsTest.testMetrics Key: KAFKA-6380 URL: https://issues.apache.org/jira/browse/KAFKA-6380 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6379) Work for KIP-240

Tom Bentley created KAFKA-6379: -- Summary: Work for KIP-240 Key: KAFKA-6379 URL: https://issues.apache.org/jira/browse/KAFKA-6379 Project: Kafka Issue Type: Bug Reporter: Tom Bentley