Tag: spring-kafka
Die Spring für Apache Kafka (spring-kafka) Projekt gilt Kern Frühjahr Konzepte für die Entwicklung der Kafka-basierten messaging-Lösungen.
Transaktion Synchronisation im Frühjahr Kafka
2 Antworten
Ich möchte zum synchronisieren von kafka Transaktion mit einem repository-Transaktion: @Transactional public void syncTransaction(){ myRepository.save(someObject) kafkaTemplate.send(someEvent) } Seit dem merge (https://github.com/spring-projects/spring-kafka/issues/373) und laut dem doc ist dies möglich. Dennoch habe ich Probleme zu verstehen und zu implementieren
Apache Kafka: Replay-Nachrichten in einem Thema
2 Antworten
Ich überlege mir mit Apache Kafka als Ereignis-Speicher für die Speicherung von Ereignissen innerhalb einer microservice. Eine Sache, die ich Lesen Sie durch die verschiedenen blogs ist, dass Kafka sein kann, als eine einzige Quelle der Wahrheit,
Kafka-Streams mit Spring Boot
3 Antworten
Hey Leute, ich möchte die Arbeit mit Kafka-Streams Echtzeit-Verarbeitung in meine spring-boot-Projekt. Also ich brauche Kafka-Streams-Konfiguration oder möchte ich KStreams oder KTable, aber ich konnte nicht finden, etwa im internet. Habe ich Erzeuger und Verbraucher jetzt will
Dead letter-Warteschlange (DLQ) für Kafka mit Feder-kafka
1 Antworten
Was ist der beste Weg zur Umsetzung Dead letter-Warteschlange (DLQ) Konzept in Spring-Boot-2.0-Anwendung mit spring-kafka 2.1.x alle Nachrichten konnte nicht verarbeitet werden @KafkaListener Methode von einigen bean geschickt, um einige vordefinierte Kafka DLQ Thema nicht zu verlieren
Spring Boot Kafka: kann Nicht starten Verbraucher durch NoSuchBeanDefinitionException
2 Antworten
Mit in meine Feder-boot-service beim starten einer kafka-Verbraucher sehen NoSuchBeanDefinitionException und konnte nicht starten Sie den Dienst selbst. Unten ist mein bean-Klasse, das über alle erforderlichen beans erstellt für Kafka Konfiguration Spring Boot-Version: 1.5.2.RELEASE import java.util.HashMap; import
Ungültige UTF-8-middle-byte 0x72
2 Antworten
Bin ich mit dem JsonSerializer und JsonDeserializer im Frühjahr-kafka, um den Wert serializer beim erzeugen einer Nachricht. Die Nachricht hat ein Feld(orgName)mit einem speziellen Zeichen (Deutsche Umlaute).Wie gehe ich mit diesen besonderen Charakter? Ich weiß JsonDeserializer verwendet
org.apache.kafka.common.KafkaException: Fehler beim konstruieren kafka Verbraucher
2 Antworten
Ich bin manuell starten, Tierpfleger, dann Kafka-server und schließlich die Kafka-Rest-server mit Ihren jeweiligen Eigenschaften-Datei. Weiter bin ich der Nutzung meiner Spring-Boot-Anwendung, die auf tomcat In das Tomcat-log trace, erhalte ich den Fehler org.springframework.context.ApplicationContextException: Failed to start
Einfache embedded-Kafka-test Beispiel mit spring boot
2 Antworten
Bearbeiten FYI: arbeiten gitHub-Beispiel War ich im internet zu suchen und nichts finden konnte, arbeiten und einfaches Beispiel für ein embedded-Kafka-test. Mein setup ist: Spring boot Mehrere @KafkaListener mit verschiedenen Themen in einer Klasse Embedded Kafka für
Kafka producer TimeoutException: Auslaufender 1 record(s)
2 Antworten
Ich bin mit Kafka mit Spring-boot: Kafka-Producer-Klasse: @Service public class MyKafkaProducer { @Autowired private KafkaTemplate<String, String> kafkaTemplate; private static Logger LOGGER = LoggerFactory.getLogger(NotificationDispatcherSender.class); //Send Message public void sendMessage(String topicName, String message) throws Exception { LOGGER.debug("========topic Name===== "