[jira] [Updated] (KAFKA-7483) Streams should allow headers to be passed to Serializer

2018-10-04 Thread Kamal Chandraprakash (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-7483: Description: We are storing schema metadata for record key and value in the

[jira] [Updated] (KAFKA-7483) Streams should allow headers to be passed to Serializer

2018-10-04 Thread Kamal Chandraprakash (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-7483: Description: We are storing schema metadata for record key and value in the

[jira] [Created] (KAFKA-7483) Streams should allow headers to be passed to Serializer

2018-10-04 Thread Kamal Chandraprakash (JIRA)
Kamal Chandraprakash created KAFKA-7483: --- Summary: Streams should allow headers to be passed to Serializer Key: KAFKA-7483 URL: https://issues.apache.org/jira/browse/KAFKA-7483 Project: Kafka

[jira] [Updated] (KAFKA-7483) Streams should allow headers to be passed to Serializer

2018-10-04 Thread Kamal Chandraprakash (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-7483: Description: We are storing schema metadata for record key and value in the

[jira] [Resolved] (KAFKA-7476) SchemaProjector is not properly handling Date-based logical types

2018-10-04 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7476. -- Resolution: Fixed Fix Version/s: 2.1.0 0.10.2.3

[jira] [Commented] (KAFKA-7476) SchemaProjector is not properly handling Date-based logical types

2018-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639221#comment-16639221 ] ASF GitHub Bot commented on KAFKA-7476: --- ewencp closed pull request #5736: KAFKA-7476: Fix

[jira] [Comment Edited] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread TAO XIAO (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639173#comment-16639173 ] TAO XIAO edited comment on KAFKA-7274 at 10/5/18 2:22 AM: -- [~rsivaram] Thanks

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread TAO XIAO (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639173#comment-16639173 ] TAO XIAO commented on KAFKA-7274: - [~rsivaram] Thanks for the explanation. What if I want to do it the

[jira] [Commented] (KAFKA-7482) LeaderAndIsrRequest should be sent to the shutting down broker

2018-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639149#comment-16639149 ] ASF GitHub Bot commented on KAFKA-7482: --- junrao opened a new pull request #5745: KAFKA-7482:

[jira] [Created] (KAFKA-7482) LeaderAndIsrRequest should be sent to the shutting down broker

2018-10-04 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-7482: -- Summary: LeaderAndIsrRequest should be sent to the shutting down broker Key: KAFKA-7482 URL: https://issues.apache.org/jira/browse/KAFKA-7482 Project: Kafka Issue

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-04 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639095#comment-16639095 ] Ismael Juma commented on KAFKA-7481: Another option would be to introduce a new config. Option 2 may

[jira] [Created] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-04 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7481: -- Summary: Consider options for safer upgrade of offset commit value schema Key: KAFKA-7481 URL: https://issues.apache.org/jira/browse/KAFKA-7481 Project: Kafka

[jira] [Resolved] (KAFKA-7441) Allow LogCleanerManager.resumeCleaning() to be used concurrently

2018-10-04 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7441. - Resolution: Fixed > Allow LogCleanerManager.resumeCleaning() to be used concurrently >

[jira] [Commented] (KAFKA-7441) Allow LogCleanerManager.resumeCleaning() to be used concurrently

2018-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639070#comment-16639070 ] ASF GitHub Bot commented on KAFKA-7441: --- lindong28 closed pull request #5694: KAFKA-7441; Allow

[jira] [Resolved] (KAFKA-7415) OffsetsForLeaderEpoch may incorrectly respond with undefined epoch causing truncation to HW

2018-10-04 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7415. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 >

[jira] [Commented] (KAFKA-3816) Provide more context in Kafka Connect log messages using MDC

2018-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638999#comment-16638999 ] ASF GitHub Bot commented on KAFKA-3816: --- rhauch opened a new pull request #5743: KAFKA-3816: Add

[jira] [Commented] (KAFKA-7415) OffsetsForLeaderEpoch may incorrectly respond with undefined epoch causing truncation to HW

2018-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638878#comment-16638878 ] ASF GitHub Bot commented on KAFKA-7415: --- hachikuji closed pull request #5678: KAFKA-7415; Persist

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

2018-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638828#comment-16638828 ] ASF GitHub Bot commented on KAFKA-7223: --- vvcephei opened a new pull request #5742: KAFKA-7223: Add

[jira] [Commented] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

2018-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638459#comment-16638459 ] ASF GitHub Bot commented on KAFKA-7196: --- lindong28 closed pull request #5556: KAFKA-7196: Remove

[jira] [Updated] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

2018-10-04 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7196: Fix Version/s: (was: 2.2.0) 2.1.0 2.0.1 1.1.2

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638347#comment-16638347 ] Manikumar commented on KAFKA-7274: -- [~rsivaram] Thanks for the explanation. Let me know, if we need to

[jira] [Reopened] (KAFKA-7477) Improve Streams close timeout semantics

2018-10-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7477: > Improve Streams close timeout semantics > --- > >

[jira] [Resolved] (KAFKA-7477) Improve Streams close timeout semantics

2018-10-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7477. Resolution: Fixed > Improve Streams close timeout semantics >

[jira] [Updated] (KAFKA-7477) Improve Streams close timeout semantics

2018-10-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7477: --- Labels: kip newbie (was: newbie) > Improve Streams close timeout semantics >

[jira] [Updated] (KAFKA-7477) Improve Streams close timeout semantics

2018-10-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7477: --- Description: See [https://github.com/apache/kafka/pull/5682#discussion_r221473451] The

[jira] [Comment Edited] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638384#comment-16638384 ] Rajini Sivaram edited comment on KAFKA-7274 at 10/4/18 3:32 PM:

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638384#comment-16638384 ] Rajini Sivaram commented on KAFKA-7274: --- [~xiaotao183] You have {code:java}

[jira] [Created] (KAFKA-7480) GlobalThread should honor custom auto.offset.reset policy

2018-10-04 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-7480: -- Summary: GlobalThread should honor custom auto.offset.reset policy Key: KAFKA-7480 URL: https://issues.apache.org/jira/browse/KAFKA-7480 Project: Kafka

[jira] [Comment Edited] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread TAO XIAO (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638357#comment-16638357 ] TAO XIAO edited comment on KAFKA-7274 at 10/4/18 3:10 PM: -- [~rsivaram] The use

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread TAO XIAO (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638357#comment-16638357 ] TAO XIAO commented on KAFKA-7274: - [~rsivaram] The use case we want is having two different mechanisms

[jira] [Comment Edited] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638297#comment-16638297 ] Rajini Sivaram edited comment on KAFKA-7274 at 10/4/18 2:36 PM:

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638297#comment-16638297 ] Rajini Sivaram commented on KAFKA-7274: --- [~xiaotao183] Actually, I dont think we have conflicting

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638293#comment-16638293 ] Rajini Sivaram commented on KAFKA-7274: --- [~xiaotao183] Yes the docs were written at a time when we

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread TAO XIAO (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638281#comment-16638281 ] TAO XIAO commented on KAFKA-7274: - [~rsivaram] should we mention it in the doc?  The example provided in

[jira] [Created] (KAFKA-7479) Call to "producer.initTransaction" hangs when using IP for "bootstrap.servers"

2018-10-04 Thread Gene B. (JIRA)
Gene B. created KAFKA-7479: -- Summary: Call to "producer.initTransaction" hangs when using IP for "bootstrap.servers" Key: KAFKA-7479 URL: https://issues.apache.org/jira/browse/KAFKA-7479 Project: Kafka

[jira] [Commented] (KAFKA-7479) Call to "producer.initTransaction" hangs when using IP for "bootstrap.servers"

2018-10-04 Thread Gene B. (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638256#comment-16638256 ] Gene B. commented on KAFKA-7479: I tried this with various client versions: 1.1.X and even 2.0.X, but the

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638250#comment-16638250 ] Rajini Sivaram commented on KAFKA-7274: --- Sorry didn't read the full description of the Jira which

[jira] [Updated] (KAFKA-7479) Call to "producer.initTransaction" hangs when using IP for "bootstrap.servers"

2018-10-04 Thread Gene B. (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gene B. updated KAFKA-7479: --- Attachment: KafkaProducerSample.java > Call to "producer.initTransaction" hangs when using IP for

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638247#comment-16638247 ] Rajini Sivaram commented on KAFKA-7274: --- As of 2.0.0, we can use the broker config

[jira] [Comment Edited] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638247#comment-16638247 ] Rajini Sivaram edited comment on KAFKA-7274 at 10/4/18 1:50 PM: As of

[jira] [Commented] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

2018-10-04 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638241#comment-16638241 ] Manikumar commented on KAFKA-7274: -- [~rsivaram] As described in the JIRA, incase of static JAAS

[jira] [Commented] (KAFKA-1421) Error: Could not find or load main class kafka.perf.SimpleConsumerPerformance

2018-10-04 Thread Haochen He (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638035#comment-16638035 ] Haochen He commented on KAFKA-1421: --- So what is the solution? I encounter this problem with 

[jira] [Assigned] (KAFKA-7477) Improve Streams close timeout semantics

2018-10-04 Thread Nikolay Izhikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikolay Izhikov reassigned KAFKA-7477: -- Assignee: Nikolay Izhikov > Improve Streams close timeout semantics >

[jira] [Commented] (KAFKA-7478) Reduce OAuthBearerLoginModule verbosity

2018-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16637955#comment-16637955 ] ASF GitHub Bot commented on KAFKA-7478: --- stanislavkozlovski opened a new pull request #5738:

[jira] [Created] (KAFKA-7478) Reduce OAuthBearerLoginModule verbosity

2018-10-04 Thread Stanislav Kozlovski (JIRA)
Stanislav Kozlovski created KAFKA-7478: -- Summary: Reduce OAuthBearerLoginModule verbosity Key: KAFKA-7478 URL: https://issues.apache.org/jira/browse/KAFKA-7478 Project: Kafka Issue

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

2018-10-04 Thread Kobi Hikri (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16637926#comment-16637926 ] Kobi Hikri commented on KAFKA-1194: --- [~manme...@gmail.com], Unfortunately, this workaround isn't