[jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518860#comment-16518860 ] Matthias J. Sax commented on KAFKA-6817: Thanks for reporting back [~col...@scangarella.com]! >

[jira] [Commented] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518856#comment-16518856 ] xiaojing zhou commented on KAFKA-7078: -- [~huxi_2b] I'm sure it is 

[jira] [Commented] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518797#comment-16518797 ] huxihx commented on KAFKA-7078: --- [~zxj1009] Does

[jira] [Resolved] (KAFKA-7072) Kafka Streams may drop rocksb window segments before they expire

[ https://issues.apache.org/jira/browse/KAFKA-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7072. -- Resolution: Fixed > Kafka Streams may drop rocksb window segments before they expire >

[jira] [Commented] (KAFKA-7072) Kafka Streams may drop rocksb window segments before they expire

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

[jira] [Commented] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518790#comment-16518790 ] Nishanth Pradeep commented on KAFKA-7075: - Hello [~guozhang], I would like to take this up if

[jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518766#comment-16518766 ] Collin Scangarella commented on KAFKA-6817: --- Thank you Matthias. In case anyone arrives with

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518753#comment-16518753 ] Ismael Juma commented on KAFKA-7012: Unless it's deemed a blocker, it would wait until 1.1.2. >

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518751#comment-16518751 ] Dong Lin commented on KAFKA-7012: - [~mjsax] It is not included in RC0 for 1.1.1. I just updated the "fix

[jira] [Updated] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7012: Fix Version/s: (was: 1.1.1) 1.1.2 > Performance issue upgrading to kafka 1.0.1 or

[jira] [Commented] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches

[ https://issues.apache.org/jira/browse/KAFKA-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518719#comment-16518719 ] ASF GitHub Bot commented on KAFKA-5764: --- umaanbazhagan opened a new pull request #5260: KAFKA-5764;

[jira] [Commented] (KAFKA-7024) Rocksdb state directory should be created before opening the DB

[ https://issues.apache.org/jira/browse/KAFKA-7024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518656#comment-16518656 ] Guozhang Wang commented on KAFKA-7024: -- [~abhishek.agarwal] Thanks for the detailed explanation. In

[jira] [Commented] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518634#comment-16518634 ] Matthias J. Sax commented on KAFKA-7041: [~nthean] Thanks for investigating this ticket. While

[jira] [Issue Comment Deleted] (KAFKA-7074) Race condition between Kafka log deletion and compaction

[ https://issues.apache.org/jira/browse/KAFKA-7074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah updated KAFKA-7074: Comment: was deleted (was: Thanks, [~phil.mikhailov]. Could you also attach broker logs from

[jira] [Comment Edited] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518598#comment-16518598 ] Nikki Thean edited comment on KAFKA-7041 at 6/20/18 9:35 PM: - Hi [~mjsax], I

[jira] [Commented] (KAFKA-7074) Race condition between Kafka log deletion and compaction

[ https://issues.apache.org/jira/browse/KAFKA-7074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518626#comment-16518626 ] Dhruvil Shah commented on KAFKA-7074: - Thanks, [~phil.mikhailov]. Could you also attach broker logs

[jira] [Commented] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518598#comment-16518598 ] Nikki Thean commented on KAFKA-7041: Hi [~mjsax], I was interested in taking this ticket, but looked

[jira] [Updated] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException

[ https://issues.apache.org/jira/browse/KAFKA-7082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7082: --- Priority: Critical (was: Major) > Concurrent createTopics calls may throw NodeExistsException >

[jira] [Created] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException

Ismael Juma created KAFKA-7082: -- Summary: Concurrent createTopics calls may throw NodeExistsException Key: KAFKA-7082 URL: https://issues.apache.org/jira/browse/KAFKA-7082 Project: Kafka Issue

[jira] [Commented] (KAFKA-6080) Transactional EoS for source connectors

[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518447#comment-16518447 ] Sönke Liebau commented on KAFKA-6080: - Would it make sense to add a fourth subtype of SourceRecord

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518445#comment-16518445 ] Ismael Juma commented on KAFKA-7012: Yes, I think this may have missed the 1.1.1 cut. > Performance

[jira] [Comment Edited] (KAFKA-7081) Add describe all topics API to AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-7081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518410#comment-16518410 ] Manikumar edited comment on KAFKA-7081 at 6/20/18 6:02 PM: --- [~ijuma] 

[jira] [Commented] (KAFKA-7081) Add describe all topics API to AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-7081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518410#comment-16518410 ] Manikumar commented on KAFKA-7081: -- [~ijuma]  [~cmccabe] Would like to get your opinion before starting

[jira] [Updated] (KAFKA-7081) Add describe all topics API to AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-7081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7081: - Description: Currently AdminClient supports describeTopics(Collection topicNames) method for topic

[jira] [Created] (KAFKA-7081) Add describe all topics API to AdminClient

Manikumar created KAFKA-7081: Summary: Add describe all topics API to AdminClient Key: KAFKA-7081 URL: https://issues.apache.org/jira/browse/KAFKA-7081 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-2435) More optimally balanced partition assignment strategy

[ https://issues.apache.org/jira/browse/KAFKA-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-2435: -- Fix Version/s: (was: 2.0.0) > More optimally balanced partition assignment strategy >

[jira] [Updated] (KAFKA-6783) consumer poll(timeout) blocked infinitely when no available bootstrap server

[ https://issues.apache.org/jira/browse/KAFKA-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6783: -- Fix Version/s: (was: 2.0.0) Description: {code:java} @Test public void

[jira] [Updated] (KAFKA-5632) Message headers not supported by Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-5632: -- Fix Version/s: (was: 2.0.0) > Message headers not supported by Kafka Streams >

[jira] [Updated] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6395: -- Fix Version/s: (was: 2.0.0) > KIP: Add Record Header support to Kafka Streams >

[jira] [Updated] (KAFKA-7008) Consider replacing the Resource field in AclBinding with a ResourceFilter or ResourceMatcher

[ https://issues.apache.org/jira/browse/KAFKA-7008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7008: -- Fix Version/s: (was: 2.0.0) > Consider replacing the Resource field in AclBinding with a

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518387#comment-16518387 ] Matthias J. Sax commented on KAFKA-7012: [~rsivaram] [~lindong] Was this cherry-picked to 1.1

[jira] [Resolved] (KAFKA-6546) Add ENDPOINT_NOT_FOUND_ON_LEADER error code for missing listener

[ https://issues.apache.org/jira/browse/KAFKA-6546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6546. --- Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: (was: 2.1.0)

[jira] [Updated] (KAFKA-7076) Broker startup could be inefficient when using old message format

[ https://issues.apache.org/jira/browse/KAFKA-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7076: -- Fix Version/s: (was: 2.0.0) Removed fix version for 2.0.0 RC0, will update if merged for

[jira] [Updated] (KAFKA-7063) Update documentation to remove references to old producers and consumers

[ https://issues.apache.org/jira/browse/KAFKA-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7063: -- Fix Version/s: (was: 2.0.0) Removed fix version for 2.0.0 RC0, will update when merged. >

[jira] [Updated] (KAFKA-6949) alterReplicaLogDirs() should grab partition lock when accessing log of the future replica

[ https://issues.apache.org/jira/browse/KAFKA-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6949: -- Fix Version/s: (was: 2.0.0) Removed fix version for 2.0.0 RC0, will update for next RC if

[jira] [Commented] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518371#comment-16518371 ] ASF GitHub Bot commented on KAFKA-7080: --- vvcephei opened a new pull request #5257: KAFKA-7080:

[jira] [Commented] (KAFKA-7079) ValueTransformer#transform does not pass the key

[ https://issues.apache.org/jira/browse/KAFKA-7079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518365#comment-16518365 ] Matthias J. Sax commented on KAFKA-7079: Are you aware of

[jira] [Assigned] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis reassigned KAFKA-6914: - Assignee: Konstantine Karantasis > Kafka Connect - Plugins class should

[jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518357#comment-16518357 ] Konstantine Karantasis commented on KAFKA-6914: --- I'm in favor of the change. All I can say

[jira] [Created] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore

John Roesler created KAFKA-7080: --- Summary: WindowStoreBuilder incorrectly initializes CachingWindowStore Key: KAFKA-7080 URL: https://issues.apache.org/jira/browse/KAFKA-7080 Project: Kafka

[jira] [Commented] (KAFKA-7020) Error when deleting topic with access denied exception

[ https://issues.apache.org/jira/browse/KAFKA-7020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518342#comment-16518342 ] wade wu commented on KAFKA-7020: [~vahid] and this issue is similar to another one, there's also another

[jira] [Commented] (KAFKA-6546) Add ENDPOINT_NOT_FOUND_ON_LEADER error code for missing listener

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

[jira] [Updated] (KAFKA-7060) Command-line overrides for ConnectDistributed worker properties

[ https://issues.apache.org/jira/browse/KAFKA-7060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7060: - Labels: needs-kip (was: ) > Command-line overrides for ConnectDistributed worker properties >

[jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518176#comment-16518176 ] Ismael Juma commented on KAFKA-7044: The odd thing is that the `endOffsets` should never return

[jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518169#comment-16518169 ] Ismael Juma commented on KAFKA-7044: The issue happens in the following lines: {code} val

[jira] [Commented] (KAFKA-7074) Race condition between Kafka log deletion and compaction

[ https://issues.apache.org/jira/browse/KAFKA-7074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518119#comment-16518119 ] Phil Mikhailov commented on KAFKA-7074: --- Hi [~dhruvilshah] Thank you for your prompt response. See

[jira] [Updated] (KAFKA-7074) Race condition between Kafka log deletion and compaction

[ https://issues.apache.org/jira/browse/KAFKA-7074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-7074: -- Attachment: LogCleanerError.log > Race condition between Kafka log deletion and compaction >

[jira] [Created] (KAFKA-7079) ValueTransformer#transform does not pass the key

Hashan Gayasri Udugahapattuwa created KAFKA-7079: Summary: ValueTransformer#transform does not pass the key Key: KAFKA-7079 URL: https://issues.apache.org/jira/browse/KAFKA-7079

[jira] [Comment Edited] (KAFKA-6594) 第二次启动kafka是报错00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。

[ https://issues.apache.org/jira/browse/KAFKA-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517968#comment-16517968 ] CHIH-HUNG CHIEN edited comment on KAFKA-6594 at 6/20/18 9:38 AM: - Hi 兴强,

[jira] [Commented] (KAFKA-6594) 第二次启动kafka是报错00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。

[ https://issues.apache.org/jira/browse/KAFKA-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517968#comment-16517968 ] CHIH-HUNG CHIEN commented on KAFKA-6594: Hi 兴强, Kafka might be shutdown inappropriately, there

[jira] [Updated] (KAFKA-7074) Race condition between Kafka log deletion and compaction

[ https://issues.apache.org/jira/browse/KAFKA-7074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-7074: -- Description: We have one of standard options of deploying Kafka-based EventSourcing

[jira] [Resolved] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3018. -- Resolution: Duplicate Resolving this as duplicate of KAFKA-5098.  Please reopen if you think otherwise

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517937#comment-16517937 ] Rajini Sivaram commented on KAFKA-7012: --- [~rajadayalanvdms] [~lindong] [~mjsax] I have

[jira] [Updated] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7012: -- Fix Version/s: 1.1.1 1.0.2 > Performance issue upgrading to kafka 1.0.1 or

[jira] [Created] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

xiaojing zhou created KAFKA-7078: Summary: Kafka 1.0.1 Broker version crashes when deleting log Key: KAFKA-7078 URL: https://issues.apache.org/jira/browse/KAFKA-7078 Project: Kafka Issue

[jira] [Commented] (KAFKA-6697) JBOD configured broker should not die if log directory is invalid

[ https://issues.apache.org/jira/browse/KAFKA-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517907#comment-16517907 ] ASF GitHub Bot commented on KAFKA-6697: --- ijuma closed pull request #4752: KAFKA-6697; JBOD

[jira] [Updated] (KAFKA-7077) producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true)

[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-7077: --- Description: KIP Link:

[jira] [Updated] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-7077: --- Summary: KIP-318: Make Kafka Connect Source idempotent (was:

[jira] [Created] (KAFKA-7077) producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true)

Stephane Maarek created KAFKA-7077: -- Summary: producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true) Key: KAFKA-7077 URL: