[jira] [Created] (KAFKA-9199) Improve handling of out of sequence errors lower than last acked sequence

Jason Gustafson created KAFKA-9199: -- Summary: Improve handling of out of sequence errors lower than last acked sequence Key: KAFKA-9199 URL: https://issues.apache.org/jira/browse/KAFKA-9199 Project:

Re: doubt in kafka

Hi Rakesh, generally, you don’t worry too much about the partitions, they’re mostly for processing parallelism. Instead, you use the topics themselves to route data where you want it to go. but in case you really want a specific Consumer to handle a specific partition, you can use ‘assign’

Build failed in Jenkins: kafka-trunk-jdk8 #4046

See Changes: [ismael] MINOR: More efficient midpoint calc for AbstractIndex (#5378) -- [...truncated 1.38 MB...] at

Re: doubt in kafka

But then again one can manually assign partitions if required. On Sun, 17 Nov 2019, 9:35 am Boyang Chen, wrote: > Hey Rajesh, > > Consumer has a self managed assign mode to read from the topic you choose. > > Boyang > > Get Outlook for iOS >

Re: doubt in kafka

Hey Rajesh, Consumer has a self managed assign mode to read from the topic you choose. Boyang Get Outlook for iOS From: Rakesh Reddy Donti Reddy Sent: Saturday, November 16, 2019 10:36:50 PM To: dev@kafka.apache.org Subject: doubt in

doubt in kafka

hello, I'm rakesh from hyderabad working in netindia pvt ltd. my company wants me to work on kafka,i have a question on kafka Q: If a producer has to send data to a some x partition in a topic , then how can i assign a consumer to read data from that particular x partition?? Thanking you in

Build failed in Jenkins: kafka-trunk-jdk11 #961

See Changes: [ismael] MINOR: More efficient midpoint calc for AbstractIndex (#5378) -- [...truncated 2.35 MB...] kafka.network.SocketServerTest >

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

Thanks a lot Levani! On 11/16/19 4:00 AM, Levani Kokhreidze wrote: > Matthias, > > Yes, I agree. KIP is updated: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-221%3A+Enhance+DSL+with+Connecting+Topic+Creation+and+Repartition+Hint > >

[jira] [Resolved] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

[ https://issues.apache.org/jira/browse/KAFKA-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9198. Resolution: Duplicate > StopReplica handler should complete pending purgatory operations >

Re: [jira] [Created] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

Looks like it is the same issue as https://issues.apache.org/jira/browse/KAFKA-8571 And there is a PR for that https://github.com/apache/kafka/pull/7069 Jason Gustafson (Jira) 于2019年11月16日周六 上午9:57写道： > Jason Gustafson created KAFKA-9198: > -- > >

[jira] [Created] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

Jason Gustafson created KAFKA-9198: -- Summary: StopReplica handler should complete pending purgatory operations Key: KAFKA-9198 URL: https://issues.apache.org/jira/browse/KAFKA-9198 Project: Kafka

Build failed in Jenkins: kafka-trunk-jdk8 #4045

See Changes: [manikumar] MINOR: add dependency analysis debugging tasks -- [...truncated 8.27 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Build failed in Jenkins: kafka-2.4-jdk8 #75

See Changes: [manikumar] MINOR: add dependency analysis debugging tasks -- [...truncated 2.69 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

Matthias, Yes, I agree. KIP is updated: https://cwiki.apache.org/confluence/display/KAFKA/KIP-221%3A+Enhance+DSL+with+Connecting+Topic+Creation+and+Repartition+Hint and

[jira] [Created] (KAFKA-9197) Consider introducing numberOfPartitions configuration field to Grouped configuration class

Levani Kokhreidze created KAFKA-9197: Summary: Consider introducing numberOfPartitions configuration field to Grouped configuration class Key: KAFKA-9197 URL: https://issues.apache.org/jira/browse/KAFKA-9197

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

Levani, do you agree to the current proposal? It's basically a de-scoping of the already voted KIP. If you agree, could you update the KIP wiki page accordingly, including the "Rejected Alternative" section (and mabye a link to a follow up Jira ticket). Because it's a descope, and John and