You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Is the key field same as the partition number? if not how i can I specify for consumer to read only specific partition data for ApacheKafkaConsumer step(version 1.7)
The text was updated successfully, but these errors were encountered:
Key in Kafka used for spreading messages over different partitions.
"In Kafka producer, a partition key can be specified to indicate the
destination partition of the message. By default, a hashing-based
partitioner is used to determine the partition id given the key, and people
can use customized partitioners also." (
https://cwiki.apache.org/confluence/display/KAFKA/FAQ).
You can build your logic of reading from a particular partition based on
key value combined with custom partitioner (
https://howtoprogram.xyz/2016/06/04/write-apache-kafka-custom-partitioner/)
On Thu, Jun 21, 2018 at 11:51 PM leenaKhilnani18 ***@***.***> wrote:
Is the key field same as the partition number? if not how i can I specify
for consumer to read only specific partition data for ApacheKafkaConsumer
step(version 1.7)
—
You are receiving this because you are subscribed to this thread.
Reply to this email directly, view it on GitHub
<#30>,
or mute the thread
<https://github.com/notifications/unsubscribe-auth/AAJpO2VjjCxh4V78V65oSRvoZbgle3lZks5t_AdFgaJpZM4UyvzB>
.
Is the key field same as the partition number? if not how i can I specify for consumer to read only specific partition data for ApacheKafkaConsumer step(version 1.7)
The text was updated successfully, but these errors were encountered: