Hallo zusammen,
ich möchte eine nachricht ins kafkatopic produzieren. Die Nachricht hat folgender Muster:
{"targetFileInfo":{"path":"/row01-small-01.txt.ready"},"sourceFileInfo":{"lastModifiedTime":1525437960000,"file":"/row01-small-01.txt.ready","filename":"row01-small-01.txt.ready","size":19728,"remoteUri":"ftp://waws-prod-am2-191.windows.net/data/orsted-real/inbound/row01","contentEncoding":"","contentType":""}}
Diese nachricht ist vom typ json, kann mir einer dabei helfen?
Mein Code bis jetz:
ich möchte eine nachricht ins kafkatopic produzieren. Die Nachricht hat folgender Muster:
{"targetFileInfo":{"path":"/row01-small-01.txt.ready"},"sourceFileInfo":{"lastModifiedTime":1525437960000,"file":"/row01-small-01.txt.ready","filename":"row01-small-01.txt.ready","size":19728,"remoteUri":"ftp://waws-prod-am2-191.windows.net/data/orsted-real/inbound/row01","contentEncoding":"","contentType":""}}
Diese nachricht ist vom typ json, kann mir einer dabei helfen?
Mein Code bis jetz:
Code:
Producer<String, String> producer = null;
Properties props = new Properties();
props.put("bootstrap.servers", "51.144.73.73:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
producer = new KafkaProducer<>(props);