apache-kafka

3热度

2回答

在asp.net web.config中有两个部分，我正在寻找关于它们实际代表的内容（比特或字节）的权威词汇。第一： <system.webServer> <security> <requestFiltering> <requestLimits maxAllowedContentLength="?" /> </requestFiltering> <

4热度

3回答

Spring：如何获取bean层次结构？

是否有可能获得注入bean的bean（通过Spring框架）？如果是的话，怎么样？谢谢！帕特里克

2热度

3回答

如何订购Docker容器的Kafka启动shell脚本？

我正试着装一个卡夫卡服务器。对于卡夫卡服务器正常启动顺序是这样的： A: start Zookeeper server B: start Broker server C: create topic 项目A和B是长时间运行的过程。并且C需要等待B启动并运行。所以我写了一个Dockerfile，与ENTRYPOINT执行shell脚本用于上述顺序： #!/bin/sh $KAFKA_HO

0热度

1回答

Python-Kafka：程序以交互模式运行，而不是以脚本模式运行

我试图通过Machine_1中的python脚本向Machine_2中的卡夫卡主题发送一些消息。 Machine_2和Machine_1都在同一个网络中，都是Azure中的虚拟机。代码：sampl.py from kafka import KafkaProducer Producer = KafkaProducer(bootstrap_servers=['Machine_2:9092'])

0热度

1回答

弹簧卡夫卡例如

我读了following doc: 不工作，并尝试运行代码：不调用 @SpringBootApplication public class Application implements CommandLineRunner { public static Logger logger = LoggerFactory.getLogger(Application.class);

2热度

1回答

是否可以使用Kafka Streams访问消息标题？

在卡夫卡0.11中添加了Headers到记录（ProducerRecord & ConsumerRecord），在使用Kafka Streams处理主题时是否可以获取这些标题？当在KStream调用诸如map方法提供了key和记录的value的论点，但没有办法，我可以看到访问headers。如果我们可以通过map而不是ConsumerRecord这将是很好的。 ex。 KStreamBuilder

2热度

1回答

Kafka Streams KTable商店与更改日志主题与日志压缩的源主题

我正在建立KTable的输入主题，我加入了两个Kafka流应用程序实例的KStream。 KTable的输入主题已经是日志压缩主题。因此，当我的应用程序实例中的一个出现故障时，另一个实例状态存储库似乎通过从输入日志压缩主题中读取而刷新整个状态。因此，不需要为我的KTable商店启用日志记录（更改日志）？我的源输入日志压缩的主题可能有数百万条记录，所以如果我在该KTable状态存储上启用日志记录

0热度

1回答

Debezium可以配置table_name => kafka主题映射吗？

我读过http://debezium.io/docs/connectors/mysql/，但我找不到任何有关是否可以配置debezium的信息，以便可以将来自2（或更多）表的更改写入同一个单独的kafka主题？在我看来，它总是1表 - > 1主题。

0热度

1回答

Flink Streaming示例：Kafka010Example.scala不起作用

我试图运行官方的“Kafka010Example.scala”，但unortunatelly它不会从输入主题读取并按预期方式写入输出。我错过了什么或做错了什么？任何帮助或暗示大加赞赏。这也正是我所做的：在泊坞窗容器（Spotify的/卡夫卡：最新）开始卡夫卡 $ docker run -d -p 2181:2181 -p 9092:9092 spotify/kafka:latest 开始的容器内

1热度

1回答

卡夫卡监制错误到期的课题10余结果：XXXXXX：因为批创建6686 ms是否已过加上盘桓时间

卡夫卡版本：0.10.2.1，卡夫卡监制错误到期10条（个），主题： XXXXXX：因为批创建6686 ms是否已过加上盘桓时间 org.apache.kafka.common.errors.TimeoutException：到期10条（个），主题：XXXXXX：6686毫秒自批创建通过加逗留时间任何线索将不胜感激。