Производитель kafka не может опубликовать сообщение в java -jar, но отлично работает в mvn Spring-boot:run или отладчикеJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Производитель kafka не может опубликовать сообщение в java -jar, но отлично работает в mvn Spring-boot:run или отладчике

Сообщение Anonymous »

Издатель Kafka отправляет сообщение с помощью

Код: Выделить всё

@Bean
public KafkaTemplate kafkaTemplate() {
return new KafkaTemplate(producerFactory());
}

@Bean
public ProducerFactory producerFactory() {

configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1:9092");
configProps.put("spring.kafka.bootstrap-servers", "127.0.0.1:9092");
configProps.put("spring.kafka.consumer.auto-offset-reset","earliest");
configProps.put("spring.kafka.consumer.group-id","data-group");
configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,         StringSerializer.class.getName());
configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,  ByteArraySerializer.class.getName());

configProps.put(ConsumerConfig.CLIENT_ID_CONFIG,"ClientIDdata-group");
return new DefaultKafkaProducerFactory(configProps);
}

ListenableFuture futureResult =  kafkaTemplate.send(topic, binarydata);
futureResult.addCallback(PublishCallback());
Если приведенный выше фрагмент запускается с помощью mvn, данные Spring-boot:run публикуются, но после компиляции кода в jar и запуска java -jar данные не публикуются. в журнале нет ошибок.
Убедено, что клиент kafka 2.7.1 включен в jar и добавлен в pom.xml

Подробнее здесь: https://stackoverflow.com/questions/779 ... -mvn-sprin
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»