[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

[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] [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&focusedCommentId=16294913#comment-16294913 ] Charles Crain commented on KAFKA-6373: -- As an update, going back to the 0.11.0.2 clie

[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&focusedCommentId=16294913#comment-16294913 ] Charles Crain edited comment on KAFKA-6373 at 12/18/17 12:40 PM: ---

[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&focusedCommentId=16295019#comment-16295019 ] Bill Bejeck commented on KAFKA-6373: Hi Charles, Thanks for reporting this. It looks

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

[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&focusedCommentId=16295019#comment-16295019 ] Bill Bejeck edited comment on KAFKA-6373 at 12/18/17 2:02 PM: --

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

[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&focusedCommentId=16295281#comment-16295281 ] Ryan Leslie commented on KAFKA-6287: Thanks for reviewing. I agree that the protocol t

[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&focusedCommentId=16295291#comment-16295291 ] Charles Crain commented on KAFKA-6373: -- Yep that looks like the same issue!! Feel fr

[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&focusedCommentId=16295315#comment-16295315 ] Randall Hauch commented on KAFKA-6353: -- [~airbots], per https://kafka.apache.org/cont

[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&focusedCommentId=16295377#comment-16295377 ] Chen He commented on KAFKA-6353: Thank you, Mr. [~rhauch]. Just sent the email. Also som

[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&focusedCommentId=16295400#comment-16295400 ] Rong Tang commented on KAFKA-6375: -- [~huxi_2b] The firewall on that Windows machine is :

[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&focusedCommentId=16295406#comment-16295406 ] Matthias J. Sax commented on KAFKA-6323: It's a fair question. I personally like c

[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&focusedCommentId=16295412#comment-16295412 ] Matthias J. Sax commented on KAFKA-6328: Thanks for the patch. Please assign the J

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

[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&focusedCommentId=16295486#comment-16295486 ] Guozhang Wang commented on KAFKA-6376: -- Regarding 3), what I meant is that in user's

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

[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 > kafka.api.AdminClientIntegrationTest.testLogStartOffsetC

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

[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&focusedCommentId=16295558#comment-16295558 ] Richard Yu commented on KAFKA-6328: --- Sorry, I am currently operating on "one active PR"

[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&focusedCommentId=16295597#comment-16295597 ] Matthias J. Sax commented on KAFKA-6328: You can create as many branches in your o

[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&focusedCommentId=16295599#comment-16295599 ] Jason Gustafson commented on KAFKA-6336: I tested using manual assignment on 0.10.

[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&focusedCommentId=16295649#comment-16295649 ] Guozhang Wang commented on KAFKA-5285: -- I'll let [~damianguy] to chime in more on thi

[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&focusedCommentId=16295659#comment-16295659 ] Stu commented on KAFKA-2359: Granted, I may be using Kafka in a place where another queue woul

[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&focusedCommentId=16295659#comment-16295659 ] Stu edited comment on KAFKA-2359 at 12/18/17 9:05 PM: -- Granted, I may

[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&focusedCommentId=16295659#comment-16295659 ] Stu edited comment on KAFKA-2359 at 12/18/17 9:05 PM: -- Granted, I may

[jira] [Assigned] (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 reassigned KAFKA-6328: - Assignee: Richard Yu > Exclude node groups belonging to global stores in > InternalTopologyBuild

[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&focusedCommentId=16295749#comment-16295749 ] ASF GitHub Bot commented on KAFKA-6328: --- GitHub user ConcurrencyPractitioner opened

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

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

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

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

[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&focusedCommentId=16295780#comment-16295780 ] ASF GitHub Bot commented on KAFKA-6382: --- GitHub user mjsax opened a pull request:

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

[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&focusedCommentId=16295813#comment-16295813 ] Joerg Heinicke edited comment on KAFKA-6366 at 12/18/17 11:03 PM: --

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

[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: https://buil

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

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

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

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

[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&focusedCommentId=16296048#comment-16296048 ] huxihx commented on KAFKA-6375: --- [~trjianjianjiao] LeaderAndIsr might not be impacted althou

[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&focusedCommentId=16296063#comment-16296063 ] Rong Tang edited comment on KAFKA-6375 at 12/19/17 2:45 AM: [~

[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&focusedCommentId=16296063#comment-16296063 ] Rong Tang commented on KAFKA-6375: -- [~huxi_2b] The LeaderAndIsr is not impacted. and th

[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&focusedCommentId=16296063#comment-16296063 ] Rong Tang edited comment on KAFKA-6375 at 12/19/17 2:46 AM: [~

[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&focusedCommentId=16296063#comment-16296063 ] Rong Tang edited comment on KAFKA-6375 at 12/19/17 2:47 AM: [~

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

[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] [Commented] (KAFKA-6265) GlobalKTable missing #queryableStoreName()

[ https://issues.apache.org/jira/browse/KAFKA-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296276#comment-16296276 ] ASF GitHub Bot commented on KAFKA-6265: --- Github user ConcurrencyPractitioner closed

[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&focusedCommentId=16296290#comment-16296290 ] Richard Yu commented on KAFKA-6328: --- [~guozhang] I have the minor suspicion that global

[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&focusedCommentId=16296412#comment-16296412 ] ASF GitHub Bot commented on KAFKA-4263: --- GitHub user mjsax opened a pull request: