ITdaan
花费 7ms 找到182条记录
Kafka - Delayed Queue implementation using high level consumer 繁体
2015年08月02 - Want to implement a delayed consumer using the high level consumer api 希望使用高级使用者api实现延迟使用者 main id

How to use kafka on tornado? 繁体
2016年02月12 - I'm trying to make a simple chat app using tornado based on this 我正在尝试使用基于此的龙卷风制作一个简单的聊天应用程序 But al

Kafka - Unable to send a message to a remote server using Java 繁体
2015年01月26 - I'm trying to create a Kafka cluster to send messages to a remote control. I have configured everyth

spark-streaming batch interval for kafka topic reprocessing 繁体
2016年11月09 - Current setting: a Spark Streaming job processes a Kafka topic of timeseries data. About every secon

KafkaUtils.createDirectStream returns a “error: type arguments” in scala 繁体
2016年11月16 - I'm trying to consume a Kafka topic from Spark with KafkaUtils.createDirectStream. I don't know if i

Creating a topic for Apache Kafka 0.9 Using Java 繁体
2016年04月01 - I am programming a client to work with kafka 0.9. I want to know how to create a topic. This answer:

Read Existing Avro File and Send to Kafka 繁体
2017年06月06 - I have an existing Avro File with the schema. I need to send the file to Producer. 我有一个现有的Avro文件与架构。

Kafka Consumers throwing java.lang.OutOfMemoryError: Direct buffer memory 繁体
2017年03月20 - I am using single node Kafka broker (0.10.2) and single node zookeeper broker (3.4.9). I am having a

How to write a correct callback to a get function that includes Promises? 繁体
2016年07月28 - I am trying to write a health check for my code (This check involved communication with Cassandra DB

Offsets stored in Zookeeper or Kafka? 繁体
2016年12月14 - I'm a bit confused about where offsets are stored when using Kafka and Zookeeper. It seems like offs


 
粤ICP备14056181号  © 2014-2021 ITdaan.com