[jira] [Created] (KAFKA-8378) kafka start error when topic data error

2019-05-17 Thread ulysses you (JIRA)
ulysses you created KAFKA-8378: -- Summary: kafka start error when topic data error Key: KAFKA-8378 URL: https://issues.apache.org/jira/browse/KAFKA-8378 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-8378) Kafka start error when topic data error

2019-05-17 Thread ulysses you (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ulysses you updated KAFKA-8378: --- Description: When start kafka server, controller log output error log, but not show what topic error

[jira] [Commented] (KAFKA-8265) Connect Client Config Override policy

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842002#comment-16842002 ] ASF GitHub Bot commented on KAFKA-8265: --- ijuma commented on pull request #6624: KAF

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-05-17 Thread Mateusz Owczarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842015#comment-16842015 ] Mateusz Owczarek commented on KAFKA-5998: - [~guozhang] Any updates on this? I hav

[jira] [Created] (KAFKA-8379) Flaky test KafkaAdminClientTest.testUnreachableBootstrapServer

2019-05-17 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-8379: - Summary: Flaky test KafkaAdminClientTest.testUnreachableBootstrapServer Key: KAFKA-8379 URL: https://issues.apache.org/jira/browse/KAFKA-8379 Project: Kafka

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842047#comment-16842047 ] Matthias J. Sax commented on KAFKA-7895: As pointed out in the email John linked

[jira] [Commented] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842063#comment-16842063 ] Matthias J. Sax commented on KAFKA-8347: [~ableegoldman] The "affects version" fi

[jira] [Commented] (KAFKA-8379) Flaky test KafkaAdminClientTest.testUnreachableBootstrapServer

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842071#comment-16842071 ] ASF GitHub Bot commented on KAFKA-8379: --- rajinisivaram commented on pull request #6

[jira] [Commented] (KAFKA-8183) Trogdor - ProduceBench should retry on UnknownTopicOrPartitionException during topic creation

2019-05-17 Thread Stanislav Kozlovski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842109#comment-16842109 ] Stanislav Kozlovski commented on KAFKA-8183: The merged PR did not seem to fi

[jira] [Commented] (KAFKA-8379) Flaky test KafkaAdminClientTest.testUnreachableBootstrapServer

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842165#comment-16842165 ] ASF GitHub Bot commented on KAFKA-8379: --- rajinisivaram commented on pull request #6

[jira] [Created] (KAFKA-8380) I can not create a topic, immediately write to it and then read.

2019-05-17 Thread Darya Merkureva (JIRA)
Darya Merkureva created KAFKA-8380: -- Summary: I can not create a topic, immediately write to it and then read. Key: KAFKA-8380 URL: https://issues.apache.org/jira/browse/KAFKA-8380 Project: Kafka

[jira] [Updated] (KAFKA-8380) We can not create a topic, immediately write to it and then read.

2019-05-17 Thread Darya Merkureva (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Darya Merkureva updated KAFKA-8380: --- Summary: We can not create a topic, immediately write to it and then read. (was: I can not c

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-17 Thread Pavel Savov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842266#comment-16842266 ] Pavel Savov commented on KAFKA-8367: Still no joy, I'm afraid. I built from that bran

[jira] [Resolved] (KAFKA-8379) Flaky test KafkaAdminClientTest.testUnreachableBootstrapServer

2019-05-17 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8379. --- Resolution: Fixed Reviewer: Ismael Juma > Flaky test KafkaAdminClientTest.testUnreachab

[jira] [Commented] (KAFKA-8034) Replace DeleteTopics request/response with automated protocol

2019-05-17 Thread Mickael Maison (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842285#comment-16842285 ] Mickael Maison commented on KAFKA-8034: --- The PR was merged, marking as Resolved >

[jira] [Resolved] (KAFKA-8034) Replace DeleteTopics request/response with automated protocol

2019-05-17 Thread Mickael Maison (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-8034. --- Resolution: Fixed > Replace DeleteTopics request/response with automated protocol > -

[jira] [Resolved] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

2019-05-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7190. -- Resolution: Fixed Fix Version/s: 2.3.0 > Under low traffic conditions purging repartitio

[jira] [Assigned] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8324: -- Assignee: Sophie Blee-Goldman > User constructed RocksObjects leak memory > --

[jira] [Resolved] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8324. Resolution: Fixed Fix Version/s: 2.3.0 > User constructed RocksObjects leak memory >

[jira] [Updated] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8324: --- Description: Some of the RocksDB options a user can set when extending RocksDBConfigSetter  t

[jira] [Updated] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8324: --- Labels: kip (was: ) > User constructed RocksObjects leak memory > --

[jira] [Created] (KAFKA-8381) SSL factory for inter-broker listener is broken

2019-05-17 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-8381: - Summary: SSL factory for inter-broker listener is broken Key: KAFKA-8381 URL: https://issues.apache.org/jira/browse/KAFKA-8381 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-8382) Add TimestampedSessionStore

2019-05-17 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-8382: -- Summary: Add TimestampedSessionStore Key: KAFKA-8382 URL: https://issues.apache.org/jira/browse/KAFKA-8382 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-8265) Connect Client Config Override policy

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842322#comment-16842322 ] ASF GitHub Bot commented on KAFKA-8265: --- mageshn commented on pull request #6755: K

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842343#comment-16842343 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6756: KAF

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Affects Version/s: (was: 2.3.0) 2.2.0

[jira] [Commented] (KAFKA-8381) SSL factory for inter-broker listener is broken

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842381#comment-16842381 ] ASF GitHub Bot commented on KAFKA-8381: --- rajinisivaram commented on pull request #6

[jira] [Commented] (KAFKA-8052) Intermittent INVALID_FETCH_SESSION_EPOCH error on FETCH request

2019-05-17 Thread Andrew Olson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842386#comment-16842386 ] Andrew Olson commented on KAFKA-8052: - [~rsivaram] There are some comments on your pu

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Affects Version/s: (was: 2.1.1) 2.1.0 > Choose next record

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8347: --- Affects Version/s: (was: 2.2.0) > Choose next record to process by timestamp > --

[jira] [Resolved] (KAFKA-8354) Replace SyncGroup request/response with automated protocol

2019-05-17 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8354. Resolution: Fixed > Replace SyncGroup request/response with automated protocol > --

[jira] [Commented] (KAFKA-8215) Limit memory usage of RocksDB

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842558#comment-16842558 ] ASF GitHub Bot commented on KAFKA-8215: --- bbejeck commented on pull request #6743: K

[jira] [Resolved] (KAFKA-8215) Limit memory usage of RocksDB

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8215. Resolution: Fixed > Limit memory usage of RocksDB > - >

[jira] [Updated] (KAFKA-8215) Limit memory usage of RocksDB

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8215: --- Fix Version/s: 2.3.0 > Limit memory usage of RocksDB > -

[jira] [Assigned] (KAFKA-8215) Limit memory usage of RocksDB

2019-05-17 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8215: -- Assignee: Bill Bejeck > Limit memory usage of RocksDB > - > >

[jira] [Assigned] (KAFKA-8215) Limit memory usage of RocksDB

2019-05-17 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8215: -- Assignee: Sophie Blee-Goldman (was: Bill Bejeck) > Limit memory usage of RocksDB > --

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-17 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842566#comment-16842566 ] John Roesler commented on KAFKA-8315: - The existing behavior of the consumer is effec

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842568#comment-16842568 ] Matthias J. Sax commented on KAFKA-8315: Agreed. As mentioned above:  https://iss

[jira] [Commented] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842620#comment-16842620 ] Bill Bejeck commented on KAFKA-8347: cherry-picked to 2.2 and 2.1 > Choose next reco

[jira] [Created] (KAFKA-8383) Write integration test for electLeaders

2019-05-17 Thread Jose Armando Garcia Sancio (JIRA)
Jose Armando Garcia Sancio created KAFKA-8383: - Summary: Write integration test for electLeaders Key: KAFKA-8383 URL: https://issues.apache.org/jira/browse/KAFKA-8383 Project: Kafka

[jira] [Created] (KAFKA-8384) Write integration tests for leader election command

2019-05-17 Thread Jose Armando Garcia Sancio (JIRA)
Jose Armando Garcia Sancio created KAFKA-8384: - Summary: Write integration tests for leader election command Key: KAFKA-8384 URL: https://issues.apache.org/jira/browse/KAFKA-8384 Project: K

[jira] [Created] (KAFKA-8385) Fix leader election RPC for all partition so that only partition that had elections are returned

2019-05-17 Thread Jose Armando Garcia Sancio (JIRA)
Jose Armando Garcia Sancio created KAFKA-8385: - Summary: Fix leader election RPC for all partition so that only partition that had elections are returned Key: KAFKA-8385 URL: https://issues.apache.org/

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Fix Version/s: 2.2.1 2.1.2 > Choose next record to process by time

[jira] [Assigned] (KAFKA-1983) TestEndToEndLatency can be unreliable after hard kill

2019-05-17 Thread Grayson Chao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grayson Chao reassigned KAFKA-1983: --- Assignee: (was: Grayson Chao) > TestEndToEndLatency can be unreliable after hard kill >

[jira] [Updated] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8324: --- Affects Version/s: 0.10.1.0 > User constructed RocksObjects leak memory > ---

[jira] [Commented] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842762#comment-16842762 ] ASF GitHub Bot commented on KAFKA-8346: --- hachikuji commented on pull request #6716:

[jira] [Created] (KAFKA-8386) Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available

2019-05-17 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8386: -- Summary: Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available Key: KAFKA-8386 URL: https://issues.apache.org/jira/browse/KAFKA-8386

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842778#comment-16842778 ] Sophie Blee-Goldman commented on KAFKA-8367: Bummer. Thanks for helping with

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842789#comment-16842789 ] ASF GitHub Bot commented on KAFKA-3522: --- bbejeck commented on pull request #6756: K

[jira] [Comment Edited] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842778#comment-16842778 ] Sophie Blee-Goldman edited comment on KAFKA-8367 at 5/17/19 11:11 PM: -

[jira] [Updated] (KAFKA-8286) KIP-460 Admin Leader Election RPC

2019-05-17 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8286: -- Description: Tracking issue for implementing KIP-460. Tasks: # [Done]

[jira] [Commented] (KAFKA-6455) Improve timestamp propagation at DSL level

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842810#comment-16842810 ] ASF GitHub Bot commented on KAFKA-6455: --- bbejeck commented on pull request #6725: K

[jira] [Created] (KAFKA-8387) Add `Fenced` state to AbstractCoordinator

2019-05-17 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8387: -- Summary: Add `Fenced` state to AbstractCoordinator Key: KAFKA-8387 URL: https://issues.apache.org/jira/browse/KAFKA-8387 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-17 Thread Richard Yu (JIRA)
Richard Yu created KAFKA-8388: - Summary: Add methods to query for entries in KTable using timestamp Key: KAFKA-8388 URL: https://issues.apache.org/jira/browse/KAFKA-8388 Project: Kafka Issue Type

[jira] [Updated] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-17 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8388: -- Description: Currently, in Kafka Streams, KTable API does not allow users to query for entries with a s

[jira] [Updated] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-17 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8388: -- Labels: needs-kip (was: ) > Add methods to query for entries in KTable using timestamp > -

[jira] [Created] (KAFKA-8389) Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest

2019-05-17 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-8389: Summary: Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest Key: KAFKA-8389 URL: https://issues.apache.org/jira/browse/KAFKA-8389 Project: Kaf

[jira] [Updated] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-17 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8388: -- Description: Currently, in Kafka Streams, KTable API does not allow users to query for entries with a

[jira] [Updated] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-17 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8388: -- Description: Currently, in Kafka Streams, KTable API does not allow users to query for entries with a

[jira] [Commented] (KAFKA-4834) Kafka cannot delete topic with ReplicaStateMachine went wrong

2019-05-17 Thread zhangxiong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843082#comment-16843082 ] zhangxiong commented on KAFKA-4834: --- same problem found in production enviroment  on ve

[jira] [Commented] (KAFKA-8365) Protocol and consumer support for follower fetching

2019-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843092#comment-16843092 ] ASF GitHub Bot commented on KAFKA-8365: --- hachikuji commented on pull request #6731:

[jira] [Resolved] (KAFKA-8365) Protocol and consumer support for follower fetching

2019-05-17 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8365. Resolution: Fixed > Protocol and consumer support for follower fetching > -