Şöyle yaparız
kafka-avro-console-producer
--broker-list localhost:9092
--topic atm-fraud-accounts-topic
--property value.schema=$(cat src/main/avro/Account.avsc | tr -d '\040\011\012\015')
--property schema.registry.url=http://localhost:8081
< test-data/accounts.txt
Hiç yorum yok:
Yorum Gönder