Kafka - Multi-Datacenter and Replication
This Kafka multi-datacenter replication code has a bug. What is it?
def replicate_message(message, datacenters):
for dc in datacenters:
if dc == "primary":
continue
datacenters[dc].append(message)
clusters = {"primary": [], "backup": []}
replicate_message("hello", clusters)
print(clusters)