Can someone please help me here? Thanks in advance Kiran Singh On Fri, Jul 21, 2017 at 11:45 AM, Kiran Singh <[email protected]> wrote:
> Hi Team, > > I am having Kafka setup as follows: > Kafka server version: 10.2 > inter.broker.protocol.version: 8.2 > log.message.format.version: 8.2 > > Kafka client version: 8.2 > > Now i need to change following properties > > inter.broker.protocol.version: 10.2 > log.message.format.version: 10.2 > > Kafka Client version: 10.2 > > > > *My question are1. Can i used same 8.2 kafka producer and kafka consumer > creation logic with Kafka client 10.2 version jar? * > > > > > > > > > > > > *Producer creation with following > properties:key.serializervalue.serializerbootstrap.serversclient.id > <http://client.id> acks retries timeout.ms <http://timeout.ms> > metadata.fetch.timeout.ms <http://metadata.fetch.timeout.ms> > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example > <https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example>* > > > > > > > > > > > > > *Consumer creation with following > properties:zookeeper.connectzookeeper.connection.timeout.ms > <http://zookeeper.connection.timeout.ms>auto.offset.resetauto.commit.enablezookeeper.session.timeout.ms > <http://zookeeper.session.timeout.ms>group.id <http://group.id>client.id > <http://client.id>offsets.storage : kafkadual.commit.enabled: > falsehttps://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example > <https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example>* > > > *2. Do you see any challenge with this approach? * > > *Thanks in advance* > > *Kiran Singh * >
