On 2019/04/02 22:43:31, jim.me...@concept-solutions.com 
<jim.me...@concept-solutions.com> wrote: 
> 
> 
> On 2019/04/02 22:25:16, jim.me...@concept-solutions.com 
> <jim.me...@concept-solutions.com> wrote: 
> > 
> > 
> > On 2019/04/02 21:59:21, Hans Jespersen <h...@confluent.io> wrote: 
> > > yes. Idempotent publish uses a unique messageID to discard potential 
> > > duplicate messages caused by failure conditions when  publishing.
> > > 
> > > -hans  
> > > 
> > > > On Apr 1, 2019, at 9:49 PM, jim.me...@concept-solutions.com 
> > > > <jim.me...@concept-solutions.com> wrote:
> > > > 
> > > > Does Kafka have something that behaves like a unique key so a producer 
> > > > can’t write the same value to a topic twice?
> > > 
> > 
> > Hi Hans,
> > 
> >     Is there some documentation or an example with source code where I can 
> > learn more about this feature and how it is implemented?
> > 
> > Thanks,
> > Jim
> > 
> 
> By the way I tried this...
>  echo "key1:value1" | ~/kafka/bin/kafka-console-producer.sh --broker-list 
> localhost:9092 --topic TestTopic --property "parse.key=true" --property 
> "key.separator=:" --property "enable.idempotence=true" > /dev/null
> 
> And... that didn't seem to do the trick - after running that command multiple 
> times I did receive key1 value1 for as many times as I had run the prior 
> command.
> 
> Maybe it is the way I am setting the flags...
> Recently I saw that someone did this...
> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 
> --producer-property enable.idempotence=true --request-required-acks -1
> 

Also... the reason for my question is that we are going to have two JMS topics 
with nearly redundant data in them have the UNION written to Kafka for further 
processing.

Reply via email to