[jira] [Resolved] (KAFKA-5509) add gradle option for building tarball with test jars

[ https://issues.apache.org/jira/browse/KAFKA-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5509. -- Resolution: Won't Fix We are going to release the testing artifact gradually in the future relea

[jira] [Updated] (KAFKA-5509) add gradle option for building tarball with test jars

[ https://issues.apache.org/jira/browse/KAFKA-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5509: - Fix Version/s: (was: 1.1.0) > add gradle option for building tarball with test jars >

[jira] [Updated] (KAFKA-4651) Improve test coverage of Stores

[ https://issues.apache.org/jira/browse/KAFKA-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4651: - Fix Version/s: (was: 1.1.0) > Improve test coverage of Stores > --

[jira] [Updated] (KAFKA-4640) Improve Streams unit test coverage

[ https://issues.apache.org/jira/browse/KAFKA-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4640: - Fix Version/s: (was: 1.1.0) 1.2.0 > Improve Streams unit test coverage > --

[jira] [Updated] (KAFKA-1548) Refactor the "replica_id" in requests

[ https://issues.apache.org/jira/browse/KAFKA-1548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1548: - Fix Version/s: (was: 1.1.0) > Refactor the "replica_id" in requests >

[jira] [Updated] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4650: - Fix Version/s: (was: 1.1.0) > Improve test coverage org.apache.kafka.streams.kstream.internals

[jira] [Updated] (KAFKA-4641) Improve test coverage of StreamsThread

[ https://issues.apache.org/jira/browse/KAFKA-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4641: - Fix Version/s: (was: 1.1.0) > Improve test coverage of StreamsThread > ---

[jira] [Updated] (KAFKA-6098) Delete and Re-create topic operation could result in race condition

[ https://issues.apache.org/jira/browse/KAFKA-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6098: - Fix Version/s: (was: 1.1.0) > Delete and Re-create topic operation could result in race condit

[jira] [Updated] (KAFKA-5533) Timestamp-based log compaction

[ https://issues.apache.org/jira/browse/KAFKA-5533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5533: - Fix Version/s: (was: 1.1.0) > Timestamp-based log compaction > --

[jira] [Updated] (KAFKA-5441) Fix transaction marker grouping by producerId in TC

[ https://issues.apache.org/jira/browse/KAFKA-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5441: - Fix Version/s: (was: 1.1.0) > Fix transaction marker grouping by producerId in TC > --

[jira] [Updated] (KAFKA-5748) Fix console producer to set timestamp and partition

[ https://issues.apache.org/jira/browse/KAFKA-5748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5748: - Fix Version/s: (was: 1.1.0) > Fix console producer to set timestamp and partition > --

[jira] [Updated] (KAFKA-5524) Streams systems tests should be with EoS

[ https://issues.apache.org/jira/browse/KAFKA-5524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5524: - Fix Version/s: (was: 1.1.0) > Streams systems tests should be with EoS > -

[jira] [Updated] (KAFKA-5493) Optimize calls to flush for tasks and standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-5493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5493: - Fix Version/s: (was: 1.1.0) > Optimize calls to flush for tasks and standby tasks > --

[jira] [Updated] (KAFKA-5219) Move transaction expiration logic and scheduling to the Transaction Manager

[ https://issues.apache.org/jira/browse/KAFKA-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5219: - Fix Version/s: (was: 1.1.0) > Move transaction expiration logic and scheduling to the Transact

[jira] [Updated] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory

[ https://issues.apache.org/jira/browse/KAFKA-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4729: - Fix Version/s: (was: 1.1.0) > Stores for kstream-kstream join cannot be in-memory > --

[jira] [Updated] (KAFKA-4730) Streams does not have an in-memory windowed store

[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4730: - Fix Version/s: (was: 1.1.0) > Streams does not have an in-memory windowed store >

[jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5037: - Fix Version/s: (was: 1.1.0) > Infinite loop if all input topics are unknown at startup > -

[jira] [Updated] (KAFKA-4904) Performance of RocksDb with state record cache

[ https://issues.apache.org/jira/browse/KAFKA-4904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4904: - Fix Version/s: (was: 1.1.0) > Performance of RocksDb with state record cache > ---

[jira] [Updated] (KAFKA-4696) Streams standby task assignment should be state-store aware

[ https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4696: - Fix Version/s: (was: 1.1.0) > Streams standby task assignment should be state-store aware > --

[jira] [Updated] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4628: - Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-4490) > Support KTable/Gl

[jira] [Updated] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4628: - Fix Version/s: (was: 1.1.0) > Support KTable/GlobalKTable Joins >

[jira] [Updated] (KAFKA-3514) Stream timestamp computation needs some further thoughts

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3514: - Fix Version/s: (was: 1.1.0) > Stream timestamp computation needs some further thoughts > -

[jira] [Resolved] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2334. -- Resolution: Fixed Assignee: (was: Neha Narkhede) Fix Version/s: (was: 1.1

[jira] [Updated] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1696: - Fix Version/s: (was: 1.1.0) > Kafka should be able to generate Hadoop delegation tokens >

[jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3978: - Fix Version/s: (was: 1.1.0) > Cannot truncate to a negative offset (-1) exception at broker st

[jira] [Resolved] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1482. -- Resolution: Cannot Reproduce Fix Version/s: (was: 1.1.0) > Transient test failures fo

[jira] [Updated] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1342: - Fix Version/s: (was: 1.1.0) > Slow controlled shutdowns can result in stale shutdown requests

[jira] [Updated] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5876: - Fix Version/s: (was: 1.1.0) 1.2.0 > IQ should throw different exceptions fo

[jira] [Updated] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4850: - Fix Version/s: (was: 1.1.0) 1.2.0 > RocksDb cannot use Bloom Filters >

[jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user

[ https://issues.apache.org/jira/browse/KAFKA-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4808: - Fix Version/s: (was: 1.1.0) 1.2.0 > send of null key to a compacted topic s

[jira] [Commented] (KAFKA-6451) Simplify KStreamReduce

[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341918#comment-16341918 ] Tanvi Jaywant commented on KAFKA-6451: -- [~sssanthalingam] [~mjsax]. Thanks for updati

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341892#comment-16341892 ] Oleksiy Stashok commented on KAFKA-2729: Thank you, that really helped! > Cached

[jira] [Updated] (KAFKA-6148) ClassCastException in BigQuery connector

[ https://issues.apache.org/jira/browse/KAFKA-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6148: -- Affects Version/s: 1.0.0 0.11.0.2 > ClassCastException in

[jira] [Updated] (KAFKA-6148) ClassCastException in BigQuery connector

[ https://issues.apache.org/jira/browse/KAFKA-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6148: -- Fix Version/s: 0.11.0.3 1.0.1 > ClassCastException in BigQuer

[jira] [Updated] (KAFKA-6288) Broken symlink interrupts scanning the plugin path

[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6288: -- Fix Version/s: 0.11.0.3 > Broken symlink interrupts scanning the plugin path > -

[jira] [Updated] (KAFKA-6288) Broken symlink interrupts scanning the plugin path

[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6288: -- Affects Version/s: 0.11.0.2 > Broken symlink interrupts scanning the plugin path

[jira] [Updated] (KAFKA-6288) Broken symlink interrupts scanning the plugin path

[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6288: -- Fix Version/s: 1.0.1 > Broken symlink interrupts scanning the plugin path >

[jira] [Commented] (KAFKA-6288) Broken symlink interrupts scanning the plugin path

[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341880#comment-16341880 ] ASF GitHub Bot commented on KAFKA-6288: --- kkonstantine opened a new pull request #448

[jira] [Commented] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value

[ https://issues.apache.org/jira/browse/KAFKA-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341864#comment-16341864 ] Prasanna Subburaj commented on KAFKA-3832: -- [~rhauch]: So should we at least let

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341863#comment-16341863 ] Jun Rao commented on KAFKA-2729: The problem that we fixed related to this jira is KAFKA-5

[jira] [Commented] (KAFKA-6490) JSON SerializationException Stops Connect

[ https://issues.apache.org/jira/browse/KAFKA-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341854#comment-16341854 ] Prasanna Subburaj commented on KAFKA-6490: -- Yes I also faces this issue. I feel t

[jira] [Closed] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamas Cserveny closed KAFKA-6483. - I've checked the KIP it will handle my case most probably. > Support ExtendedSerializer in Kafka Stre

[jira] [Commented] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets

[ https://issues.apache.org/jira/browse/KAFKA-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341828#comment-16341828 ] Prasanna Subburaj commented on KAFKA-6312: -- [~tankhiwale] You can work on this is

[jira] [Commented] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341766#comment-16341766 ] Matthias J. Sax commented on KAFKA-6483: I did not think about the details. But we

[jira] [Comment Edited] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341746#comment-16341746 ] Tamas Cserveny edited comment on KAFKA-6483 at 1/26/18 11:01 PM: ---

[jira] [Comment Edited] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341746#comment-16341746 ] Tamas Cserveny edited comment on KAFKA-6483 at 1/26/18 11:01 PM: ---

[jira] [Commented] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341746#comment-16341746 ] Tamas Cserveny commented on KAFKA-6483: --- Hi, I'm not talking about *propagating* th

[jira] [Commented] (KAFKA-6451) Simplify KStreamReduce

[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341745#comment-16341745 ] Matthias J. Sax commented on KAFKA-6451: Thanks [~sssanthalingam]. Hope you find a

[jira] [Assigned] (KAFKA-6451) Simplify KStreamReduce

[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6451: -- Assignee: Tanvi Jaywant > Simplify KStreamReduce > -- > >

[jira] [Assigned] (KAFKA-6451) Simplify KStreamReduce

[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6451: -- Assignee: (was: siva santhalingam) > Simplify KStreamReduce > -

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341725#comment-16341725 ] Oleksiy Stashok commented on KAFKA-2729: [~ijuma] can you please provide more info

[jira] [Commented] (KAFKA-6451) Simplify KStreamReduce

[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341726#comment-16341726 ] siva santhalingam commented on KAFKA-6451: -- Hi [~mjsax] I'm fine with [~tanvijayw

[jira] [Comment Edited] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341725#comment-16341725 ] Oleksiy Stashok edited comment on KAFKA-2729 at 1/26/18 10:44 PM: --

[jira] [Commented] (KAFKA-6244) Enable dynamic reconfiguration of log cleaners

[ https://issues.apache.org/jira/browse/KAFKA-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341720#comment-16341720 ] ASF GitHub Bot commented on KAFKA-6244: --- hachikuji closed pull request #4465: KAFKA-

[jira] [Updated] (KAFKA-6275) Extend consumer offset reset tool to support deletion (KIP-229)

[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-6275: --- Summary: Extend consumer offset reset tool to support deletion (KIP-229) (was: Extend consume

[jira] [Commented] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182

[ https://issues.apache.org/jira/browse/KAFKA-6354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341707#comment-16341707 ] Yu LIU commented on KAFKA-6354: --- Okay, Thanks so much [~mjsax] ! > Update KStream JavaDoc w

[jira] [Commented] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182

[ https://issues.apache.org/jira/browse/KAFKA-6354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341689#comment-16341689 ] Matthias J. Sax commented on KAFKA-6354: I just added you to the list of contribut

[jira] [Assigned] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182

[ https://issues.apache.org/jira/browse/KAFKA-6354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6354: -- Assignee: Yu LIU > Update KStream JavaDoc with regard to KIP-182 >

[jira] [Commented] (KAFKA-6451) Simplify KStreamReduce

[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341677#comment-16341677 ] Matthias J. Sax commented on KAFKA-6451: Thanks for the PR [~tanvijaywant31]. Just

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341648#comment-16341648 ] Matthias J. Sax commented on KAFKA-6035: It is best practice to assign JIRAs befor

[jira] [Assigned] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5660: -- Assignee: Nick Afshartous > Don't throw TopologyBuilderException during runtime > -

[jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341637#comment-16341637 ] Matthias J. Sax commented on KAFKA-5660: Thanks for picking this up. I added you a

[jira] [Updated] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results

[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4609: --- Summary: KTable/KTable join followed by groupBy and aggregate/count can result in duplicated r

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16341613#comment-16341613 ] Matthias J. Sax commented on KAFKA-6395: [~jeqo] Can we close this as a duplicate?

[jira] [Resolved] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6483. Resolution: Duplicate > Support ExtendedSerializer in Kafka Streams > --

[jira] [Created] (KAFKA-6491) Large uncompacted __consumer_offsets files should not make broker restarts slow

Mike Mintz created KAFKA-6491: - Summary: Large uncompacted __consumer_offsets files should not make broker restarts slow Key: KAFKA-6491 URL: https://issues.apache.org/jira/browse/KAFKA-6491 Project: Kafk

[jira] [Commented] (KAFKA-4953) Global Store: cast exception when initialising with in-memory logged state store

[ https://issues.apache.org/jira/browse/KAFKA-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341504#comment-16341504 ] ASF GitHub Bot commented on KAFKA-4953: --- guozhangwang closed pull request #2741: KAF

[jira] [Commented] (KAFKA-4898) Add timeouts to streams integration tests

[ https://issues.apache.org/jira/browse/KAFKA-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341424#comment-16341424 ] ASF GitHub Bot commented on KAFKA-4898: --- guozhangwang closed pull request #2686: KAF

[jira] [Commented] (KAFKA-5228) Revisit Streams DSL JavaDocs

[ https://issues.apache.org/jira/browse/KAFKA-5228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341422#comment-16341422 ] ASF GitHub Bot commented on KAFKA-5228: --- guozhangwang closed pull request #3047: KAF

[jira] [Commented] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341404#comment-16341404 ] James Cheng commented on KAFKA-6487: While waiting for a fix, a workaround would be to

[jira] [Comment Edited] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341374#comment-16341374 ] simonxia edited comment on KAFKA-2729 at 1/26/18 6:13 PM: -- Happen

[jira] [Comment Edited] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341374#comment-16341374 ] simonxia edited comment on KAFKA-2729 at 1/26/18 6:12 PM: -- Happen

[jira] [Comment Edited] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341374#comment-16341374 ] simonxia edited comment on KAFKA-2729 at 1/26/18 6:10 PM: -- Happen

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341374#comment-16341374 ] simonxia commented on KAFKA-2729: - Happened to me several times，version 0.10.0.0   timeli

[jira] [Commented] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

[ https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341331#comment-16341331 ] ASF GitHub Bot commented on KAFKA-6205: --- guozhangwang closed pull request #4415: KAF

[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&focusedCommentId=16341287#comment-16341287 ] Randall Hauch commented on KAFKA-6080: -- Here are some initial thoughts. First, we wa

[jira] [Resolved] (KAFKA-6467) Enforce layout of dependencies within a Connect plugin to be deterministic

[ https://issues.apache.org/jira/browse/KAFKA-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6467. Resolution: Fixed Reviewer: Jason Gustafson (was: Ewen Cheslack-Postava) > Enforce la

[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&focusedCommentId=16341260#comment-16341260 ] Randall Hauch commented on KAFKA-6080: -- We'll need a KIP to define how this is done.

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

[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6080: - Labels: needs-kip (was: ) > Transactional EoS for source connectors > ---

[jira] [Commented] (KAFKA-6467) Enforce layout of dependencies within a Connect plugin to be deterministic

[ https://issues.apache.org/jira/browse/KAFKA-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341253#comment-16341253 ] ASF GitHub Bot commented on KAFKA-6467: --- hachikuji closed pull request #4459: KAFKA-

[jira] [Resolved] (KAFKA-4991) KerberosLogin#login should probably be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-4991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4991. Resolution: Fixed Assignee: Manikumar (was: Colin P. McCabe) > KerberosLogin#login sh

[jira] [Commented] (KAFKA-4991) KerberosLogin#login should probably be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-4991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341221#comment-16341221 ] ASF GitHub Bot commented on KAFKA-4991: --- hachikuji closed pull request #4394: KAFKA-

[jira] [Created] (KAFKA-6490) JSON SerializationException Stops Connect

William R. Speirs created KAFKA-6490: Summary: JSON SerializationException Stops Connect Key: KAFKA-6490 URL: https://issues.apache.org/jira/browse/KAFKA-6490 Project: Kafka Issue Type: B