不清楚AUTO.OFFSET.RESET和ENABLE.AUTO.COMMIT在Kafka中的含义
val kafkaParams = Map[String, Object](
"bootstrap.servers" -> "master:9092,slave1:9092",
"key.deserializer" -> classOf[StringDeserializer],
"value.deserializer" -> classOf[StringDeserializer],
"group.id" -> "GROUP_2017",
"auto.offset.reset" -> "latest", //earliest or latest
"enable.auto.commit" -> (true: java.lang.Boolean)
)
共有1个答案
我会解释给你的意思，但我高度建议阅读Kafka的网站配置
"bootstrap.servers" -> "master:9092,slave1:9092"
基本上是Kafka集群配置：IP和端口。
"key.deserializer" -> classOf[StringDeserializer]
"value.deserializer" -> classOf[StringDeserializer]
这样回答说明目的是什么。
"group.id" -> "GROUP_2017"
"enable.auto.commit" -> (true: java.lang.Boolean)
"auto.offset.reset" -> "latest"
-
嗨，我正在学习Selenium&我不太清楚上面两个函数是如何工作的：问题陈述： 我有一个练习作业：转到http://the-internet.herokuapp.com/ 单击链接>多个窗口一个窗口打开>单击>>单击此处另一个窗口打开>>从该窗口获取文本并打印，然后返回http://the-internet.herokuapp.com/Windows并打印文本。 流程:http://the-int
-
本文向大家介绍Kafka 偏移量的演变清楚吗？相关面试题，主要包含被问及Kafka 偏移量的演变清楚吗？时的应答技巧和注意事项，需要的朋友参考一下 我在[《Apache Kafka消息格式的演变(0.7.x~0.10.x)》文章中介绍了 Kafka 几个版本的消息格式。仔细的同学肯定看到了在 MessageSet 中的 Message 都有一个 Offset 与之一一对应，本文将探讨 Kafka各
-
我有一个badtokenexception的报告，尽管我尝试了任何事情，但我无法复制它，对我来说也不清楚它是如何发生的。 BadTokenException(@Android.view.viewrootimpl:setView:575)通过(@Android.view.WindowmanagerGlobal:AddView:272)完整跟踪：Android.view.Windowmanager$B
-
本文向大家介绍Kafka 消息格式的演变清楚吗？相关面试题，主要包含被问及Kafka 消息格式的演变清楚吗？时的应答技巧和注意事项，需要的朋友参考一下 用 Kafka这么久，从来都没去了解 Kafka 消息的格式。今天特意去网上搜索了以下，发现这方面的资料真少，很多资料都是官方文档的翻译；而且 Kafka消息支持压缩，对于压缩消息的格式的介绍更少。基于此，本文将以图文模式介绍 Kafka 0.7.
-
我只是在尝试学习如何将基于intellij构建的java应用程序打包并安装到PC上。 我使用“C:\ProgramFiles（x86）\OpenJava\openjdk-15.0.2\U windows-x64\U bin\jdk-15.0.2”在intellij中构建了hello world，并在开发环境中运行。 如果我理解Launch4j，我可以在JRE选项卡中指定捆绑的JRE，这样我就不依赖
-
建议仅在< code>enable.auto.commit设置为< code>false时使用< code>commitSync()。但是我们使用了< code>commitSync()而忘记了将< code>enable.auto.commit设置为< code>false。所以我想知道在这种情况下会发生什么？