kafka-producer-api

0Hitze

1Antwort

Kafka, wie die neueste erstellte Partition ID für ein Thema in Java zu kennen ist

Ich erstelle Partition für ein Thema dynamisch mit AdminUtils. Ich muss die PartitionId der neu erstellten Partition abrufen, um sie in Mysql für meine Geschäftslogik zu speichern. Wie kann ich das er

1Hitze

1Antwort

Kafka-Verbraucher gibt leeren Iterator zurück

In meinem Beispielprogramm versuche ich eine Datei zu veröffentlichen und versuche, diese sofort zu verbrauchen. Aber mein Consumer-Iterator gibt null zurück. Irgendeine Idee, was ich falsch mache? -T

0Hitze

1Antwort

org.apache.kafka.common.errors.ApiException: Das Sitzungszeitlimit ist nicht in einem akzeptablen Bereich

Ich bekomme oben Ausnahme in meinem Verbraucher mit Kafka 0.9.0.1. Nach diesem Thread [1] sehe ich nicht die " group.max.session.timeout.ms "-Eigenschaft in der Datei server.properties. org.apache.kaf

2Hitze

1Antwort

Kafka: ein Fehler trat in einem kürzlich unsicheren Speicherzugriffsvorgang in kompiliertem Java-Code auf

Nach der Veröffentlichung einiger Nachrichten an Kafka, bekomme ich unten Fehler. Bitte helfen Sie ein Problem zu debuggen. Und Maschine hat genügend Speicher. [email protected]:/home/kafka/kafka/logs

1Hitze

2Antwort

kafka.common.FailedToSendMessageException: kafka produzieren Fehler

ich eine JSON-Datei lese und zu versuchen, es zu produzieren mit kafka .. Hier ist mein Code: public class FlatFileDataProducer { private String topic = "JsonTopic"; private Producer<String

0Hitze

1Antwort

Wie Verbraucherdaten mit Kafka Java api

Dies ist meine Verbraucher-Code überprüfen: public class KafkaConsumer { private ConsumerConnector consumerConnector = null; private final String topic = "JsonTopic"; public void init

0Hitze

1Antwort

Kafka immer ein Verbraucher konsumieren die Thema Nachricht in einer Gruppe

Ich habe zwei Consumer-Server mit der gleichen Gruppen-ID abonniert das gleiche Thema. Ein Kafka-Server läuft mit nur einer Partition. Soweit ich weiß, sollte die Nachricht nach dem Zufallsprinzip auf

2Hitze

1Antwort

Kafka Partition Rebalancing (Zuordnung) dauert zu viel Zeit

Wir verwenden Kafka Cluster mit 3 Servern, alle von ihnen haben auch Tierpfleger. Wir haben 7 Themen mit jeweils 6 Partitionen. Wir haben 3 Java-Konsumenten für jedes Thema. Wenn ich den Consumer star

2Hitze

1Antwort

WARN Fehler beim Abrufen von Metadaten mit der Korrelations-ID 1: {MY_TOPIC? = INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)

Wenn ich den folgenden Befehl mit kafka 0.9.0.1 ausführe, erhalte ich diese Warnungen [1]. Kannst du mir bitte sagen, was mit meinen Themen falsch ist? (Ich rede mit dem kafka Broker, die in EC2 läuft

8Hitze

2Antwort

Kafka wirft java.nio.channels.ClosedChannelException

Wenn ich versuche, Nachrichten von der kafka-Server, die in ec2 gehostet wird mit Kafka-Konsole-Tool (V 0.9.0.1, ich denke, dass dies alte Consumer APIs verwendet) bekomme ich folgende Ausnahme . Wie