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 *
