Related
Lada When I run the following command with kafka 0.9.0.1 I get this warning[1]. Can you tell me what's wrong with my theme? (I'm talking to a Kafka broker running in EC2) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic
Lada When I run the following command with kafka 0.9.0.1 I get this warning[1]. Can you tell me what's wrong with my theme? (I'm talking to a Kafka broker running in EC2) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic
Lada When I run the following command with kafka 0.9.0.1 I get this warning[1]. Can you tell me what's wrong with my theme? (I'm talking to a Kafka broker running in EC2) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic
Lada When I run the following command with kafka 0.9.0.1 I get this warning[1]. Can you tell me what's wrong with my theme? (I'm talking to a Kafka broker running in EC2) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic
Lada When I run the following command with kafka 0.9.0.1 I get this warning[1]. Can you tell me what's wrong with my theme? (I'm talking to a Kafka broker running in EC2) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic
Lada When I run the following command with kafka 0.9.0.1 I get this warning[1]. Can you tell me what's wrong with my theme? (I'm talking to a Kafka broker running in EC2) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic
Lada When I run the following command with kafka 0.9.0.1 I get this warning[1]. Can you tell me what's wrong with my theme? (I'm talking to a Kafka broker running in EC2) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic
no data
no data
Augie So I got this error with a single kafka 0.8.2.0 broker and a java consumer running in mesos. I have to say it used to work and AFAIK that hasn't changed. When the consumer runs in mesos, this is the error: 16/03/17 05:44:23 WARN ConsumerFetcherManager$Le
Augie So I got this error with a single kafka 0.8.2.0 broker and a java consumer running in mesos. I have to say it used to work and AFAIK that hasn't changed. When the consumer runs in mesos, this is the error: 16/03/17 05:44:23 WARN ConsumerFetcherManager$Le
Augie So I got this error with a single kafka 0.8.2.0 broker and a java consumer running in mesos. I have to say it used to work and AFAIK that hasn't changed. When the consumer runs in mesos, this is the error: 16/03/17 05:44:23 WARN ConsumerFetcherManager$Le
Tris I'm trying to consume messages from a kafka topic on Amazon MSK (Kafka version 2.2.1) using the NiFi ConsumeKafka_2_6 processor (NiFi version 1.12.1). In the ConsumeKafka processor I get a warning as " org.apache.kafka.clients. NetworkClient [Consumer cli
EyalP I am trying to consume events using Apache Flink. The code is pretty basic, it tries to concatenate the topic split words by topic and print it to the console. Kafka version is 0.9. import org.apache.flink.api.common.functions.FlatMapFunction;
import org
EyalP I am trying to consume events using Apache Flink. The code is pretty basic, it tries to concatenate the topic split words by topic and print it to the console. Kafka version is 0.9. import org.apache.flink.api.common.functions.FlatMapFunction;
import org
crazy synapse I sent a message to Kafka using the following code: def getHealthSink(kafkaHosts: String, zkHosts: String) = {
val kafkaHealth: Subscriber[String] = kafka.publish(ProducerProperties(
brokerList = kafkaHosts,
topic = "health_check
Gherbi Hicham: I get the error message: org.apache.kafka.common.errors.TimeoutException: Topic testtopic2 not present in metadata after 60000 ms.
When trying to generate topic in local kafka instance on windows using java. Note that the topic testtopic2 exis
Gherbi Hicham: I get the error message: org.apache.kafka.common.errors.TimeoutException: Topic testtopic2 not present in metadata after 60000 ms.
When trying to generate topic in local kafka instance on windows using java. Note that the topic testtopic2 exis
Gherbi Hicham: I get the error message: org.apache.kafka.common.errors.TimeoutException: Topic testtopic2 not present in metadata after 60000 ms.
When trying to generate topic in local kafka instance on windows using java. Note that the topic testtopic2 exis
Vaqual Khan I am using Apache Kafka version kafka_2.10-0.10.1.0 During the Poc, I created simple producer and consumer. When I try to consume the message I get the following error: Exception in thread "Thread-0" java.lang.NoSuchMethodError: org.apache.kafka.c
Vaqual Khan I am using Apache Kafka version kafka_2.10-0.10.1.0 During the Poc, I created simple producer and consumer. When I try to consume the message I get the following error: Exception in thread "Thread-0" java.lang.NoSuchMethodError: org.apache.kafka.c
Vaqual Khan I am using Apache Kafka version kafka_2.10-0.10.1.0 During the Poc, I created simple producer and consumer. When I try to consume the message I get the following error: Exception in thread "Thread-0" java.lang.NoSuchMethodError: org.apache.kafka.c
Vaqual Khan I am using Apache Kafka version kafka_2.10-0.10.1.0 During the Poc, I created simple producer and consumer. When I try to consume the message I get the following error: Exception in thread "Thread-0" java.lang.NoSuchMethodError: org.apache.kafka.c
Vaqual Khan I am using Apache Kafka version kafka_2.10-0.10.1.0 During the Poc, I created simple producer and consumer. When I try to consume the message I get the following error: Exception in thread "Thread-0" java.lang.NoSuchMethodError: org.apache.kafka.c
anonymous alias We have Kafka Connect running the postgres connector, which pulls changes from the database and puts them into the topic. we got an error ERROR WorkerSourceTask{id=wem-postgres-source-0} Failed to flush, timed out while waiting for producer to
Giorgos Myrianthous I am trying to create a kafka topic using $KAFKA_HOME/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testing
But the following error is reported: Error while executing topic command :
Giorgos Myrianthous I am trying to create a kafka topic using $KAFKA_HOME/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testing
But the following error is reported: Error while executing topic command :
Giorgos Myrianthous I am trying to create a kafka topic using $KAFKA_HOME/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testing
But the following error is reported: Error while executing topic command :
Giorgos Myrianthous I am trying to create a kafka topic using $KAFKA_HOME/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testing
But the following error is reported: Error while executing topic command :