[jira] [Commented] (KAFKA-6890) Add connector level configurability for producer/consumer client configs

[ https://issues.apache.org/jira/browse/KAFKA-6890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673918#comment-16673918 ] Peter M Elias commented on KAFKA-6890: -- I found this issue after reading through the

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673834#comment-16673834 ] Randall Hauch commented on KAFKA-7509: -- Since changing the unused property log messa

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673828#comment-16673828 ] ASF GitHub Bot commented on KAFKA-7509: --- rhauch closed pull request #5867: KAFKA-75

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673826#comment-16673826 ] ASF GitHub Bot commented on KAFKA-7509: --- rhauch opened a new pull request #5876: KA

[jira] [Commented] (KAFKA-7576) Dynamic update of replica fetcher threads may fail to start/close fetchers

[ https://issues.apache.org/jira/browse/KAFKA-7576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673801#comment-16673801 ] ASF GitHub Bot commented on KAFKA-7576: --- rajinisivaram opened a new pull request #5

[jira] [Comment Edited] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673706#comment-16673706 ] Sebastian Puzoń edited comment on KAFKA-7531 at 11/2/18 9:32 PM: --

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673706#comment-16673706 ] Sebastian Puzoń commented on KAFKA-7531: Hi Jason, here's commit id from broker:

[jira] [Created] (KAFKA-7586) Connector status endpoint HTTP response codes

Rod Cordova created KAFKA-7586: -- Summary: Connector status endpoint HTTP response codes Key: KAFKA-7586 URL: https://issues.apache.org/jira/browse/KAFKA-7586 Project: Kafka Issue Type: Improveme

[jira] [Commented] (KAFKA-7584) StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String

[ https://issues.apache.org/jira/browse/KAFKA-7584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673614#comment-16673614 ] ASF GitHub Bot commented on KAFKA-7584: --- mjsax opened a new pull request #5874: KAF

[jira] [Created] (KAFKA-7585) Avoid classloader when passing serializers to KafkaProducer constructors

Sherwin Chiu created KAFKA-7585: --- Summary: Avoid classloader when passing serializers to KafkaProducer constructors Key: KAFKA-7585 URL: https://issues.apache.org/jira/browse/KAFKA-7585 Project: Kafka

[jira] [Created] (KAFKA-7584) StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String

Matthias J. Sax created KAFKA-7584: -- Summary: StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String Key: KAFKA-7584 URL: https://issues.apache.org/jira/browse/KAFKA-7

[jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect

[ https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673444#comment-16673444 ] Matthias J. Sax commented on KAFKA-7577: TopologyTestDriver docs: [https://kafka

[jira] [Commented] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user

[ https://issues.apache.org/jira/browse/KAFKA-7580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673439#comment-16673439 ] Matthias J. Sax commented on KAFKA-7580: Unit test are not intended to fail if yo

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673371#comment-16673371 ] chris riley commented on KAFKA-7509: Just commenting to say these log warnings have b

[jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect

[ https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673137#comment-16673137 ] Daren Thomas commented on KAFKA-7577: - {quote}Can you verify that Y.leftJoin(Z) produ

[jira] [Comment Edited] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16672962#comment-16672962 ] Robert V edited comment on KAFKA-7556 at 11/2/18 11:23 AM: --- I d

[jira] [Commented] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16672962#comment-16672962 ] Robert V commented on KAFKA-7556: - I didn't see this issue with a non-compacted topics, b

[jira] [Commented] (KAFKA-7575) 'Error while writing to checkpoint file' Issue

[ https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16672832#comment-16672832 ] Dasun Nirmitha commented on KAFKA-7575: --- Hi Sonke, I ran the same application on a

[jira] [Assigned] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liju reassigned KAFKA-5054: --- Assignee: Liju > ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized >

[jira] [Commented] (KAFKA-7575) 'Error while writing to checkpoint file' Issue

[ https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16672795#comment-16672795 ] Sönke Liebau commented on KAFKA-7575: - [~nirm2009] any news on this? If not, I'd be t

[jira] [Updated] (KAFKA-7583) Unable to close kafka producer if kafka not avaibalbe

[ https://issues.apache.org/jira/browse/KAFKA-7583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitalina Horyukova updated KAFKA-7583: -- Summary: Unable to close kafka producer if kafka not avaibalbe (was: Producer force cl