Hello,
I recently upgraded our kafka cluster from Kafka version 0.10.1 to 2.3.1
I've confirmed the version has updated using the following command:
/home/wrte/install/kafka/bin/kafka-topics.sh --version
2.3.1.1_212.11 (Commit:8c923fb4c62a38ae)
However I'm unable to use the transactional features as the producer fails
with
Caused by: org.apache.kafka.common.errors.UnsupportedVersionException:
The broker does not support ADD_PARTITIONS_TO_TXN
When I double checked the broker api version, it says transactions aren't
supported:
/home/wrte/install/kafka/bin/kafka-broker-api-versions.sh
--bootstrap-server localhost:4443 | grep -i txn
EndTxn(26): UNSUPPORTED,
WriteTxnMarkers(27): UNSUPPORTED,
TxnOffsetCommit(28): UNSUPPORTED,
AddPartitionsToTxn(24): UNSUPPORTED,
AddOffsetsToTxn(25): UNSUPPORTED,
I can also see that a new topic: __transaction_state was created on the
broker. How can I fix this and start using transactions?
Thanks,
Soman
|