@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();
- for (int i = 1; i <= number; i++)
- {
- send(key, Integer.toString(i));
- }
- send(key, "CALCULATE");
+ // TODO: JSON-Nachrichten verschicken
}
- 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