Производитель 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 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение
  • Какова разница между MVN Spring-Boot: Run и «Run» в IntelliJ
    Anonymous » » в форуме JAVA
    0 Ответы
    3 Просмотры
    Последнее сообщение Anonymous
  • Какова разница между MVN Spring-Boot: Run и «Run» в IntelliJ
    Anonymous » » в форуме JAVA
    0 Ответы
    4 Просмотры
    Последнее сообщение Anonymous
  • Какова разница между MVN Spring-Boot: Run и «Run» в IntelliJ
    Anonymous » » в форуме JAVA
    0 Ответы
    3 Просмотры
    Последнее сообщение Anonymous
  • Производитель Kafka выдает сообщение «Получена неизвестная ошибка темы или раздела» при отправке в тему, созданную с пом
    Anonymous » » в форуме JAVA
    0 Ответы
    32 Просмотры
    Последнее сообщение Anonymous
  • Невозможно запустить чистую установку mvn: mvn использует плагин по умолчанию (maven-antrun-plugin:3.1.0), хотя pom опре
    Гость » » в форуме JAVA
    0 Ответы
    119 Просмотры
    Последнее сообщение Гость

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