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

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16236351#comment-16236351 ] Evgeny Veretennikov commented on KAFKA-6161: Changed issue. > Introduce new s

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

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-6161: --- Description: {{Serializer}}, {{Deserializer}} and {{Serde}} interfaces have methods {

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

[ 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: Mak

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

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16236334#comment-16236334 ] Evgeny Veretennikov commented on KAFKA-6161: Oops, didn't notice, that source

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

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] [Comment Edited] (KAFKA-4750) KeyValueIterator returns null values

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

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

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16097357#comment-16097357 ] Evgeny Veretennikov commented on KAFKA-4750: So, to sum up discussion. I shoul

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

[ 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] [Comment Edited] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

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

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

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16076472#comment-16076472 ] Evgeny Veretennikov commented on KAFKA-4468: Let me show you such example: {c

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

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16076373#comment-16076373 ] Evgeny Veretennikov commented on KAFKA-4468: Sorry, guys, I missed javadoc com

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

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16076281#comment-16076281 ] Evgeny Veretennikov commented on KAFKA-4468: I have researched windowed stores

[jira] [Resolved] (KAFKA-3823) QuickStart documentation is still showing MirrorMakers supports more than one consumer.config

[ https://issues.apache.org/jira/browse/KAFKA-3823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov resolved KAFKA-3823. Resolution: Fixed Closed issue, as [~tombentley] suggested. > QuickStart documentat

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

[ 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 broker

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

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074714#comment-16074714 ] Evgeny Veretennikov commented on KAFKA-5503: [~hachikuji], part of call stack

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

[ 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 fetc

[jira] [Assigned] (KAFKA-5531) Check exception handling in all streams tests

[ https://issues.apache.org/jira/browse/KAFKA-5531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-5531: -- Assignee: Evgeny Veretennikov > Check exception handling in all streams tests >

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

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073360#comment-16073360 ] Evgeny Veretennikov commented on KAFKA-4750: [~damianguy] [~enothereska] what

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

[ 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 serde

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

[ 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 bloc

[jira] [Commented] (KAFKA-5535) Transformations - tranformations for value broken on tombstone events

[ https://issues.apache.org/jira/browse/KAFKA-5535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069714#comment-16069714 ] Evgeny Veretennikov commented on KAFKA-5535: I'm unable to reproduce this. Cou

[jira] [Updated] (KAFKA-5535) Transformations - tranformations for value broken on tombstone events

[ https://issues.apache.org/jira/browse/KAFKA-5535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-5535: --- Summary: Transformations - tranformations for value broken on tombstone events (was:

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

[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068191#comment-16068191 ] Evgeny Veretennikov commented on KAFKA-5212: [~hachikuji], I'd like to work on

[jira] [Created] (KAFKA-5529) ConsoleProducer uses deprecated BaseProducer

Evgeny Veretennikov created KAFKA-5529: -- Summary: ConsoleProducer uses deprecated BaseProducer Key: KAFKA-5529 URL: https://issues.apache.org/jira/browse/KAFKA-5529 Project: Kafka Issue

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

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065021#comment-16065021 ] Evgeny Veretennikov commented on KAFKA-4468: [~guozhang], I'm not sure, what d

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

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16064473#comment-16064473 ] Evgeny Veretennikov commented on KAFKA-4750: If we don't implement {{delete()}

[jira] [Created] (KAFKA-5511) ConfigDef.define() overloads take too many parameters

Evgeny Veretennikov created KAFKA-5511: -- Summary: ConfigDef.define() overloads take too many parameters Key: KAFKA-5511 URL: https://issues.apache.org/jira/browse/KAFKA-5511 Project: Kafka

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

[ 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 wit

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

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062575#comment-16062575 ] Evgeny Veretennikov commented on KAFKA-4750: If we invoke {{store.put(key, val

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

[ https://issues.apache.org/jira/browse/KAFKA-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16061962#comment-16061962 ] Evgeny Veretennikov commented on KAFKA-4388: [~ewencp], does header in this ti

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

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-4750: --- Attachment: DeleteTest.java > KeyValueIterator returns null values > -

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

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16061898#comment-16061898 ] Evgeny Veretennikov commented on KAFKA-4750: [~mjsax], are you sure about call

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

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16061243#comment-16061243 ] Evgeny Veretennikov commented on KAFKA-4750: I guess, problem lies in {{KeyVal

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

[ 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 r

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

[ 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. R

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

[ 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. R

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

[ 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. R

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

[ 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. R

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

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