I’m having trouble getting three kafka brokers to form a cluster. Two will join a cluster but one can’t (it was rejected).
They are named:
- kafka01
- kafka03
- kafka04
The brokers are containers running in Docker Swarm (each on a node) on Ubuntu 22.04.
I logged into kafka01 and ran kafka-broker-api-versions with the --version option passing the each server’s ip. I got the following:
- kafka01 → kafka01: 7.3.0-ccs
- kafka01 → kafka03: 7.3.0-ccs
- kafka01 → kafka04: 7.3.0-css
Everything is matching up thus far.
I ran each command again but not with the --version flag. kafka01 and kafka04 looked fine. However, kafka03 had the following output:
(
Produce(0): UNSUPPORTED,
Fetch(1): 0 to 13 [usable: 13],
ListOffsets(2): UNSUPPORTED,
Metadata(3): UNSUPPORTED,
LeaderAndIsr(4): UNSUPPORTED,
StopReplica(5): UNSUPPORTED,
UpdateMetadata(6): UNSUPPORTED,
ControlledShutdown(7): 0 to 3 [usable: 3],
OffsetCommit(8): UNSUPPORTED,
OffsetFetch(9): UNSUPPORTED,
FindCoordinator(10): UNSUPPORTED,
JoinGroup(11): UNSUPPORTED,
Heartbeat(12): UNSUPPORTED,
LeaveGroup(13): UNSUPPORTED,
SyncGroup(14): UNSUPPORTED,
DescribeGroups(15): UNSUPPORTED,
ListGroups(16): UNSUPPORTED,
SaslHandshake(17): 0 to 1 [usable: 1],
ApiVersions(18): 0 to 3 [usable: 3],
CreateTopics(19): 0 to 7 [usable: 7],
DeleteTopics(20): 0 to 6 [usable: 6],
DeleteRecords(21): UNSUPPORTED,
InitProducerId(22): UNSUPPORTED,
OffsetForLeaderEpoch(23): UNSUPPORTED,
AddPartitionsToTxn(24): UNSUPPORTED,
AddOffsetsToTxn(25): UNSUPPORTED,
EndTxn(26): UNSUPPORTED,
WriteTxnMarkers(27): UNSUPPORTED,
TxnOffsetCommit(28): UNSUPPORTED,
DescribeAcls(29): 0 to 3 [usable: 3],
CreateAcls(30): 0 to 3 [usable: 3],
DeleteAcls(31): 0 to 3 [usable: 3],
DescribeConfigs(32): UNSUPPORTED,
AlterConfigs(33): 0 to 2 [usable: 2],
AlterReplicaLogDirs(34): UNSUPPORTED,
DescribeLogDirs(35): UNSUPPORTED,
SaslAuthenticate(36): 0 to 2 [usable: 2],
CreatePartitions(37): 0 to 3 [usable: 3],
CreateDelegationToken(38): UNSUPPORTED,
RenewDelegationToken(39): UNSUPPORTED,
ExpireDelegationToken(40): UNSUPPORTED,
DescribeDelegationToken(41): UNSUPPORTED,
DeleteGroups(42): UNSUPPORTED,
ElectLeaders(43): 0 to 2 [usable: 2],
IncrementalAlterConfigs(44): 0 to 1 [usable: 1],
AlterPartitionReassignments(45): 0 [usable: 0],
ListPartitionReassignments(46): 0 [usable: 0],
OffsetDelete(47): UNSUPPORTED,
DescribeClientQuotas(48): UNSUPPORTED,
AlterClientQuotas(49): 0 to 1 [usable: 1],
DescribeUserScramCredentials(50): UNSUPPORTED,
AlterUserScramCredentials(51): UNSUPPORTED,
Vote(52): 0 [usable: 0],
BeginQuorumEpoch(53): 0 [usable: 0],
EndQuorumEpoch(54): 0 [usable: 0],
DescribeQuorum(55): 0 to 1 [usable: 1],
AlterPartition(56): 0 to 2 [usable: 2],
UpdateFeatures(57): 0 to 1 [usable: 1],
Envelope(58): 0 [usable: 0],
FetchSnapshot(59): 0 [usable: 0],
DescribeCluster(60): UNSUPPORTED,
DescribeProducers(61): UNSUPPORTED,
BrokerRegistration(62): 0 [usable: 0],
BrokerHeartbeat(63): 0 [usable: 0],
UnregisterBroker(64): 0 [usable: 0],
DescribeTransactions(65): UNSUPPORTED,
ListTransactions(66): UNSUPPORTED,
AllocateProducerIds(67): 0 [usable: 0]
)
When I logged into kafk03 and ran the kafka-broker-api-version command on itself (just to sanity check), the output looked fine (as expected).
Based on my situation, does anyone know what could be causing the issue with kafka03 not being able to join the cluster? Does anyone know why APIs, like Produce, JoinGroup, etc, are marked as UNSUPPORTED (those are really important)?
