[jira] [Created] (KAFKA-6932) Avroconverter does not propagate subjectname stratergy

Masthan Shaik created KAFKA-6932: Summary: Avroconverter does not propagate subjectname stratergy Key: KAFKA-6932 URL: https://issues.apache.org/jira/browse/KAFKA-6932 Project: Kafka Issue

[jira] [Updated] (KAFKA-6930) Update KafkaZkClient debug log

[ https://issues.apache.org/jira/browse/KAFKA-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] darion yaphet updated KAFKA-6930: - Priority: Trivial (was: Major) > Update KafkaZkClient debug log > --

[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=16486603#comment-16486603 ] Ewen Cheslack-Postava commented on KAFKA-6914: -- [~sriramks85] Not sure I understand the use

[jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site

[ https://issues.apache.org/jira/browse/KAFKA-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486583#comment-16486583 ] Ravi Raj Singh commented on KAFKA-4559: --- Submitted pull request for adding search to the Kafka site.

[jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site

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

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 5/23/18 12:51 AM: - +1 was (Author:

[jira] [Commented] (KAFKA-6886) Externalize Secrets for Kafka Connect Configurations

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

[jira] [Commented] (KAFKA-6786) Remove additional configs in StreamsBrokerDownResilienceTest

[ https://issues.apache.org/jira/browse/KAFKA-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486493#comment-16486493 ] Abhishek Sharma commented on KAFKA-6786: Left a comment on the PR; facing some issues with running

[jira] [Resolved] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

[ https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6875. --- Resolution: Cannot Reproduce > EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky >

[jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 5/22/18 11:55 PM: - Thanks for taking this .

[jira] [Resolved] (KAFKA-6920) Enhance ConsumerRecordFactory and OutputVerifier for Header support

[ https://issues.apache.org/jira/browse/KAFKA-6920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6920. Resolution: Duplicate > Enhance ConsumerRecordFactory and OutputVerifier for Header support

[jira] [Commented] (KAFKA-6850) KIP-244: Add Record Header support to Kafka Streams Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484711#comment-16484711 ] ASF GitHub Bot commented on KAFKA-6850: --- mjsax closed pull request #4955: KAFKA-6850: Add Record

[jira] [Issue Comment Deleted] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6378: --- Comment: was deleted (was: wicknicks opened a new pull request #5065: KAFKA-6378: Implement

[jira] [Commented] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef

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

[jira] [Resolved] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef

[ https://issues.apache.org/jira/browse/KAFKA-5807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5807. -- Resolution: Fixed Fix Version/s: 2.0.0 Issue resolved by pull request

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

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

[jira] [Resolved] (KAFKA-2943) Transient Failure in kafka.producer.SyncProducerTest.testReachableServer

[ https://issues.apache.org/jira/browse/KAFKA-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2943. -- Resolution: Auto Closed > Transient Failure in kafka.producer.SyncProducerTest.testReachableServer >

[jira] [Resolved] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5432. -- Resolution: Auto Closed Closing inactive issue.  Exceptions observed with deprecated scala clients. 

[jira] [Resolved] (KAFKA-4419) Unable to GetOffset when the ACL of topic is defined

[ https://issues.apache.org/jira/browse/KAFKA-4419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4419. -- Resolution: Duplicate Resolving as duplicate of  KAFKA-3355. > Unable to GetOffset when the ACL of

[jira] [Resolved] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1460. -- Resolution: Auto Closed Closing inactive issue.  Please reopen if you think the issue still exists in

[jira] [Updated] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-3355: - Fix Version/s: 2.0.0 > GetOffsetShell command doesn't work with SASL enabled Kafka >

[jira] [Resolved] (KAFKA-2174) Wrong TopicMetadata deserialization

[ https://issues.apache.org/jira/browse/KAFKA-2174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2174. -- Resolution: Auto Closed Closing inactive issue. > Wrong TopicMetadata deserialization >

[jira] [Resolved] (KAFKA-3345) ProducerResponse could gracefully handle no throttle time provided

[ https://issues.apache.org/jira/browse/KAFKA-3345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3345. -- Resolution: Auto Closed Closing as scala producer is removed from codebase.

[jira] [Resolved] (KAFKA-5039) Logging in BlockingChannel and SyncProducer connect

[ https://issues.apache.org/jira/browse/KAFKA-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5039. -- Resolution: Auto Closed Closing as scala producer is removed from codebase. > Logging in

[jira] [Resolved] (KAFKA-3246) Transient Failure in kafka.producer.SyncProducerTest.testProduceCorrectlyReceivesResponse

[ https://issues.apache.org/jira/browse/KAFKA-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3246. -- Resolution: Auto Closed > Transient Failure in >

[jira] [Commented] (KAFKA-6028) Improve the quota throttle communication.

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

[jira] [Assigned] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4936: -- Assignee: Guozhang Wang > Allow dynamic routing of output records >

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

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

[jira] [Commented] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer

[ https://issues.apache.org/jira/browse/KAFKA-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484152#comment-16484152 ] Ismael Juma commented on KAFKA-6923: Yes, please pick it up. The main thing I was unsure about is the

[jira] [Commented] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer

[ https://issues.apache.org/jira/browse/KAFKA-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484144#comment-16484144 ] Viktor Somogyi commented on KAFKA-6923: --- [~ijuma] have you started working on this? I've been

[jira] [Resolved] (KAFKA-6924) Making state store queryable on replicas

[ https://issues.apache.org/jira/browse/KAFKA-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6924. -- Resolution: Duplicate > Making state store queryable on replicas >

[jira] [Commented] (KAFKA-6931) Make worker id configurable

[ https://issues.apache.org/jira/browse/KAFKA-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484113#comment-16484113 ] Chia-Ping Tsai commented on KAFKA-6931: --- the screenshot display the configurable worker id rather

[jira] [Created] (KAFKA-6931) Make worker id configurable

Chia-Ping Tsai created KAFKA-6931: - Summary: Make worker id configurable Key: KAFKA-6931 URL: https://issues.apache.org/jira/browse/KAFKA-6931 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-6931) Make worker id configurable

[ https://issues.apache.org/jira/browse/KAFKA-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-6931: -- Attachment: configurable_worker_id.png > Make worker id configurable >

[jira] [Assigned] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools

[ https://issues.apache.org/jira/browse/KAFKA-2983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Beni reassigned KAFKA-2983: -- Assignee: Ismael Juma (was: Andras Beni) [~ijuma], I have not made significant progress.

[jira] [Commented] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools

[ https://issues.apache.org/jira/browse/KAFKA-2983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484001#comment-16484001 ] Ismael Juma commented on KAFKA-2983: [~andrasbeni], have you started on this? I have an in-progress

[jira] [Commented] (KAFKA-6930) Update KafkaZkClient debug log

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

[jira] [Updated] (KAFKA-6930) Update KafkaZkClient debug log

[ https://issues.apache.org/jira/browse/KAFKA-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] darion yaphet updated KAFKA-6930: - Attachment: [KAFKA-6930]_Update_KafkaZkClient_debug_log.patch > Update KafkaZkClient debug log >

[jira] [Created] (KAFKA-6930) Update KafkaZkClient debug log

darion yaphet created KAFKA-6930: Summary: Update KafkaZkClient debug log Key: KAFKA-6930 URL: https://issues.apache.org/jira/browse/KAFKA-6930 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6929) ZkData - Consumers offsets Zookeeper path is not correct

maytal created KAFKA-6929: - Summary: ZkData - Consumers offsets Zookeeper path is not correct Key: KAFKA-6929 URL: https://issues.apache.org/jira/browse/KAFKA-6929 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483856#comment-16483856 ] Gunnar Morling commented on KAFKA-3821: --- Hey [~rhauch], thanks for getting back to this one. I don't

[jira] [Updated] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-6188: Attachment: Segments are opened before deletion > Broker fails with FATAL Shutdown - log dirs have failed >

[jira] [Commented] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483728#comment-16483728 ] Dawid Kulig commented on KAFKA-6892: I've increased container memory limit to 14 GB, and memory usage

[jira] [Resolved] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Kulig resolved KAFKA-6892. Resolution: Cannot Reproduce > Kafka Streams memory usage grows over the time till OOM >

[jira] [Assigned] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools

[ https://issues.apache.org/jira/browse/KAFKA-2983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Beni reassigned KAFKA-2983: -- Assignee: Andras Beni (was: Grant Henke) > Remove old Scala consumer and all related code,

[jira] [Commented] (KAFKA-6924) Making state store queryable on replicas

[ https://issues.apache.org/jira/browse/KAFKA-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483611#comment-16483611 ] Navinder Brar commented on KAFKA-6924: -- Hi [~guozhang] thanks for pointing it out. I believe it is

[jira] [Commented] (KAFKA-4423) Drop support for Java 7

[ https://issues.apache.org/jira/browse/KAFKA-4423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483551#comment-16483551 ] ASF GitHub Bot commented on KAFKA-4423: --- ijuma closed pull request #5046: KAFKA-4423: Drop support