Что такое Palindrome в Kafka

Палиндром (Palindrome) в Kafka — это конфигурация, при которой потребитель (consumer) и производитель (producer) работают с одним и тем же топиком. Это означает, что сообщения, отправленные в топик, могут быть прочитаны из него же тем же или другим приложением.

Пример:

// Producer
Properties producerProps = new Properties();
producerProps.put("bootstrap.servers", "localhost:9092");
producerProps.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
producerProps.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

Producer<String, String> producer = new KafkaProducer<>(producerProps);
producer.send(new ProducerRecord<>("palindrome-topic", "key", "Hello, Kafka!"));

// Consumer
Properties consumerProps = new Properties();
consumerProps.put("bootstrap.servers", "localhost:9092");
consumerProps.put("group.id", "palindrome-group");
consumerProps.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
consumerProps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

Consumer<String, String> consumer = new KafkaConsumer<>(consumerProps);
consumer.subscribe(Collections.singletonList("palindrome-topic"));
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));

Используется для тестирования, логирования или в архитектурах, где данные обрабатываются и возвращаются в тот же топик.