Null in Kafka Streams müssen entfernt werden

Question

Nur entfernen --property print.key=true dies auf meinem kafka-cosole-Consumer-Befehl funktioniert für die Anzeige von null auf der Konsole .... aber die Sache ist, es ist nicht nur für die Anzeige Zweck ich benutze. ... meine Ausgaben von kafka Ströme müssen direkt in den Stream Reaktor gehen, von dort dann influxdb .... mein Strom Reaktor

{"timestamp":"2017-10-04T10:43:56.614451246+05:30","namespace":"/intel/psutil/load/load1","data":0.42,"unit":"Load/1M","version":0,"last_advertised_time":"2017-10-04T10:43:56.669248345+05:30"} 
{"timestamp":"2017-10-04T10:43:56.61445546+05:30","namespace":"/intel/psutil/load/load5","data":0.44,"unit":"Load/5M","version":0,"last_advertised_time":"2017-10-04T10:43:56.669251145+05:30"} 

nur so viel annehmen ..... es

nicht akzeptieren

null {"timestamp":"2017-12-05T13:52:43.560588466+05:30","namespace":"/intel/procfs/meminfo/active_anon","data":4183900160,"unit":"","tags":{"plugin_running_on":"AELAB110"},"version":4,"last_advertised_time":"2017-12-05T13:52:43.560658038+05:30"} 
null {"timestamp":"2017-12-05T13:52:43.560618652+05:30","namespace":"/intel/procfs/meminfo/mem_free","data":49385746432,"unit":"","tags":{"plugin_running_on":"AELAB110"},"version":4,"last_advertised_time":"2017-12-05T13:52:43.560660098+05:30"} 

Also was kann die Lösung dafür sein? plzz helfen mir

Answer 1

Sie können entweder die Nachrichten filtern:

stream.filter(...).to(...); 

Oder Sie stellen einen Ersatzwert, der null ersetzt:

stream.map(...).to(...);