kafka 同时设置了 7 天和 10G 清除数据，到第五天的时候消息达到了 10G，这个时候 kafka 将如何处理？
-
我正在为Kafka和SparkStreaming编写一些代码，当我将它们放在Yarn-Cluster上时，它报告了。 但它在我的电脑上运行良好（独立模式） 那它有什么问题呢？ //这是代码 这里例外----------------------------------- 19/07/26 18:21:56警告Scheduler.TaskSetManager：在stage 0.0中丢失任务0.0（TI
-
本文向大家介绍kafka producer 打数据，ack 为 0， 1， -1 的时候代表啥， 设置 -1 的时候，什么情况下，leader 会认为一条消息 commit了？相关面试题，主要包含被问及kafka producer 打数据，ack 为 0， 1， -1 的时候代表啥， 设置 -1 的时候，什么情况下，leader 会认为一条消息 commit了？时的应答技巧和注意事项，需要的朋友参
-
我没有找到任何关于Debezium如何设置Kafka消息时间戳的文档，以及是否设置了时间戳。 通过比较这些值，Kafka消息的时间戳总是在数据库表（source.ts_ms）更改的时间戳之后，也在Debezium（ts_ms）处理更改的时间之后。这表明Kafka消息时间戳只是Kafka代理设置为摄入时间的时间戳。 有人知道关于Debezium是否以及如何在其填充的接收器主题中设置Kafka消息时间
-
您好，我正在尝试与JDBC建立Oracle连接。 我在Win 7 x86上运行，运行Oracle 10g R2 XE，Eclipse Java EE Juno和Java SE v1.7。自从之前使用 ojdbc 以来，我已经在 WebContent/WEB-INF/lib 中包含 class.12.jar 和 ojdbc5.jar .jar它在连接到数据库时出错。所以我不确定我到底要包括哪个驱动程
-
我刚开始学Kafka，Kafka-蟒蛇。在下面的代码中，我试图在消息到达时读取它们。但出于某种原因，消费者似乎要等到一定数量的消息积累后才能获取它们。 我最初以为是因为正在批量出版的制片人。当我运行“kafka-console-consumer--bootstrap-servers--topic”时，我可以看到发布后收到的每一条消息（就像在consumer控制台上看到的那样） 有人能指出用KafK
-
我有两个kafka代理，使用SSL的kafka-0和使用PLAINTEXT的kafka-1（使用Docker映像部署）。 我需要设置security.inter.broker.protocol，以便kafka-0和kafka-1可以相互对话。当我将两个代理都设置为明文时，kafka-0会给出以下错误: hafka-0的广告监听器是 同时，如果我将两个代理的协议都设置为SSL，kafka-1会抱怨: