apache-kafka - 代码之家

同一消费群体中具有不同分区数量的不同卡夫卡主题

yershalom · 技术社区 · apache-kafka · 2 年前

将kafka从服务器迁移到docker容器

Oskars Apinis · 技术社区 · apache-kafka docker · 2 年前

Apache kafka模式注册表问题

Sravan Kumar · 技术社区 · apache-kafka · 2 年前

无法建立到节点1(localhost/127.0.0.1:9092)的连接。经纪人可能不在。甚至传入正确的端点[重复]

Panadol Chong · 技术社区 · apache-kafka docker java · 2 年前

如何确保旧版本0.10.0在卡夫卡中只处理一次

MrSham · 技术社区 · kafka-consumer-api apache-kafka · 2 年前

Kafka-PLC4X-Modbus/TCP-作业刮取期间异常

TheTags · 技术社区 · plc4x plc apache-kafka · 2 年前

卡夫卡制作人/消费者粉碎每一秒的API调用

Iheb Mar · 技术社区 · apache-kafka scala · 2 年前

在为Nifi编写流媒体服务时,如何解决Java的空指针异常?[闭门]

hasherBaba · 技术社区 · apache-nifi apache-kafka python java · 6 年前

为storm consumer检查卡夫卡主题的偏移量

phaigeim · 技术社区 · trident offset apache-storm apache-zookeeper apache-kafka · 6 年前

Kafka流:POJO序列化/反序列化

Raman · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

Kafka ksql简单联接不起作用

Mikhail · 技术社区 · ksqldb apache-kafka · 6 年前

Kafka spark同步流处理作业

sharon gur · 技术社区 · confluent-platform spark-streaming apache-kafka apache-spark scala · 6 年前

关于使用kafka、zookeeper和elastic search运行docker compose文件时出错

aironman · 技术社区 · docker-compose apache-kafka elasticsearch spring-boot docker · 6 年前

Kafka群集未接收消息

bdparrish · 技术社区 · apache-kafka java · 6 年前

无法从表KSQL获取数据

Mikhail · 技术社区 · ksqldb apache-kafka · 6 年前

Kafka流处理期间处理数据时出现异常

Stella · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

PyKafka元数据(字节而非字符串)

Chobeat · 技术社区 · pykafka apache-kafka python · 6 年前

通过公共IP将Logstash连接到Azure中的Kafka

pm1391 · 技术社区 · logstash apache-kafka azure · 6 年前

如何在两台服务器之间创建套接字io连接

Shalabh Negi · 技术社区 · kafka-producer-api apache-kafka socket.io node.js javascript · 6 年前

kafka流中的处理器节点

Stella · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

AIOKafka:以前的工作代码现在在send\u和\u wait失败

Ali YÄ±lmaz · 技术社区 · python-asyncio apache-kafka python · 6 年前

如何从Avro模式创建有效的JSON示例?

user9750148 · 技术社区 · avro apache-kafka json · 6 年前

JAVA尝试在Flink中创建Kafka使用者时出现lang.NoClassDefFoundError(CheckpointedRestoring)

skrshn · 技术社区 · apache-flink apache-kafka maven java · 6 年前

Spring Kafka单元测试错误:无法确定TestUtils。createBrokerConfig()

如何将scala用于后端?[已关闭]

Nisal Bandara · 技术社区 · web-development-server backend apache-kafka apache-spark scala · 6 年前

如何知道卡夫卡何时提交记录?

BnJ · 技术社区 · kafka-consumer-api apache-kafka · 6 年前

为什么kafka connect分布式模式总是只分配一个任务?

Dogil · 技术社区 · apache-kafka-connect apache-kafka · 6 年前

卡夫卡到熊猫的无火花数据帧

dportman · 技术社区 · apache-kafka pandas json python · 6 年前

Spring Kafka-遇到“Magic v0不支持记录头”错误

MD10172016 · 技术社区 · spring-kafka flume cloudera apache-kafka · 6 年前

使用嵌入弹簧的Kafka测试@KafkaListener

riccardo.cardin · 技术社区 · spring-boot-test spring-kafka apache-kafka spring-boot java · 6 年前