[jira] [Assigned] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

2017-07-16 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-3539: -- Assignee: (was: Evgeny Veretennikov) > KafkaProducer.send() may block even

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-07-22 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097357#comment-16097357 ] Evgeny Veretennikov commented on KAFKA-4750: So, to sum up discussion. I should close current

[jira] [Comment Edited] (KAFKA-4750) KeyValueIterator returns null values

2017-07-22 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097357#comment-16097357 ] Evgeny Veretennikov edited comment on KAFKA-4750 at 7/22/17 3:02 PM: -

[jira] [Assigned] (KAFKA-5245) KStream builder should capture serdes

2017-07-04 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-5245: -- Assignee: (was: Evgeny Veretennikov) > KStream builder should capture

[jira] [Assigned] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

2017-07-04 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-5503: -- Assignee: Evgeny Veretennikov > Idempotent producer ignores shutdown while

[jira] [Assigned] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

2017-07-03 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-3539: -- Assignee: Evgeny Veretennikov (was: Manikumar) > KafkaProducer.send() may

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2017-07-06 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076373#comment-16076373 ] Evgeny Veretennikov commented on KAFKA-4468: Sorry, guys, I missed javadoc comment to

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2017-07-06 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076472#comment-16076472 ] Evgeny Veretennikov commented on KAFKA-4468: Let me show you such example: {code:java} final

[jira] [Comment Edited] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2017-07-06 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076472#comment-16076472 ] Evgeny Veretennikov edited comment on KAFKA-4468 at 7/6/17 1:13 PM:

[jira] [Commented] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-06-29 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16068191#comment-16068191 ] Evgeny Veretennikov commented on KAFKA-5212: [~hachikuji], I'd like to work on this ticket,

[jira] [Assigned] (KAFKA-4249) Document how to customize GC logging options for broker

2017-07-05 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-4249: -- Assignee: Tom Bentley > Document how to customize GC logging options for

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

2017-07-05 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16074714#comment-16074714 ] Evgeny Veretennikov commented on KAFKA-5503: [~hachikuji], part of call stack for blocking

[jira] [Assigned] (KAFKA-4750) KeyValueIterator returns null values

2017-06-23 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-4750: -- Assignee: Evgeny Veretennikov (was: Kamal Chandraprakash) > KeyValueIterator

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-06-23 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061243#comment-16061243 ] Evgeny Veretennikov commented on KAFKA-4750: I guess, problem lies in

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-06-24 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061898#comment-16061898 ] Evgeny Veretennikov commented on KAFKA-4750: [~mjsax], are you sure about call chain in

[jira] [Assigned] (KAFKA-4388) Connect key and value converters are listed without default values

2017-06-26 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-4388: -- Assignee: Evgeny Veretennikov > Connect key and value converters are listed

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-06-26 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062575#comment-16062575 ] Evgeny Veretennikov commented on KAFKA-4750: If we invoke {{store.put(key, value)}}, and

[jira] [Created] (KAFKA-5507) kafka-run-class.sh doesn't check for empty $CLASSPATH

2017-06-23 Thread Evgeny Veretennikov (JIRA)
Evgeny Veretennikov created KAFKA-5507: -- Summary: kafka-run-class.sh doesn't check for empty $CLASSPATH Key: KAFKA-5507 URL: https://issues.apache.org/jira/browse/KAFKA-5507 Project: Kafka

[jira] [Updated] (KAFKA-5507) kafka-run-class.sh doesn't check for empty $CLASSPATH

2017-06-23 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-5507: --- Description: Steps to reproduce problem: 1. Clone Kafka repo using {{git clone}}. 2.

[jira] [Updated] (KAFKA-5507) kafka-run-class.sh doesn't check for empty $CLASSPATH

2017-06-23 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-5507: --- Description: Steps to reproduce problem: 1. Clone Kafka repo using {{git clone}}. 2.

[jira] [Updated] (KAFKA-5507) kafka-run-class.sh doesn't check for empty $CLASSPATH

2017-06-23 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-5507: --- Description: Steps to reproduce problem: 1. Clone Kafka repo using {{git clone}}. 2.

[jira] [Updated] (KAFKA-5507) kafka-run-class.sh doesn't check for empty $CLASSPATH

2017-06-23 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-5507: --- Description: Steps to reproduce problem: 1. Clone Kafka repo using {{git clone}}. 2.

[jira] [Created] (KAFKA-6161) Make configure() and close() empty by default in serde interfaces

2017-11-02 Thread Evgeny Veretennikov (JIRA)
Evgeny Veretennikov created KAFKA-6161: -- Summary: Make configure() and close() empty by default in serde interfaces Key: KAFKA-6161 URL: https://issues.apache.org/jira/browse/KAFKA-6161 Project:

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

2017-11-02 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16236351#comment-16236351 ] Evgeny Veretennikov commented on KAFKA-6161: Changed issue. > Introduce new serdes interfaces

[jira] [Updated] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

2017-11-02 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-6161: --- Summary: Introduce new serdes interfaces with empty configure() and close() (was:

[jira] [Commented] (KAFKA-6161) Make configure() and close() empty by default in serde interfaces

2017-11-02 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16236334#comment-16236334 ] Evgeny Veretennikov commented on KAFKA-6161: Oops, didn't notice, that source compatibility is