@Slf4j
public class ApplicationRecordHandler implements RecordHandler<String, Integer>
{
- private final Producer<String, String> producer;
+ private final Producer<String, Object> producer;
private final String id;
private final String topic;
String key = record.key();
int number = record.value();
- send(key, "START");
for (int i = 1; i <= number; i++)
{
- send(key, Integer.toString(i));
+ send(key, new AddNumberMessage(number, i));
}
- send(key, "END");
+ send(key, new CalculateSumMessage(number));
}
- private void send(String key, String value)
+ private void send(String key, Object value)
{
final long time = System.currentTimeMillis();
- final ProducerRecord<String, String> record = new ProducerRecord<>(
+ final ProducerRecord<String, Object> record = new ProducerRecord<>(
topic, // Topic
key, // Key
value // Value