使用Java为Apache Kafka 0.9创建主题
我正在编程一个客户端工作与Kafka0.9。我想知道如何制造话题。这个答案：如何通过Java在Kafka中创建一个主题，与我所问的类似。除此之外，该解决方案仅适用于Kafka 0.8.2，这与Kafka 0.9的API有很大不同。
共有1个答案
我试着用Kafka0.9.0.1来回答Soon Chee Loong的答案，但不得不做一个改变。ZKStringSerializer现在是私有的。为了创建ZkUtils，我使用了以下API（它在内部创建了一个ZkClient）：
ZkUtils.apply(
"zookeeper1:port1,zookeeper2:port2",
sessionTimeoutMs,
connectionTimeoutMs,
false)
-
jOOQ具有文档中所述的CREATE TABLE语法： 我想知道如何定义哪个列属于主键？那么，在jOOQ中有没有办法用主键信息创建create TABLE语句呢？ 我对SQLite的解决方案特别感兴趣，它没有语法来添加主键，所以我认为在最坏的情况下，我必须去一个特定于数据库的解决方案？
-
问题内容： 我的MySQL数据库需要两个用户：appuser和support。 应用程序开发人员之一坚持要求我为这些用户创建四个帐户： 对于我的一生，我不知道他为什么认为我们需要这个。不会使用通配符作为主机来处理“本地主机”吗？ 有任何想法吗？ （在这里使用MySQL 5.5） 问题答案： 在MySQL中是特殊的，它表示通过UNIX套接字（我相信是Windows上的命名管道）的连接，而不是TCP
-
Atom的界面使用HTML渲染，并且通过Less来定义样式，它是CSS的超集。不要担心之前从未听说过Less，它类似于CSS，但是带有一些便捷的扩展。 Atom支持两种主题：UI和语法。UI主题为树视图、选择夹、下拉列表和状态栏之类的元素定义样式。语法主题为编辑器中的代码定义样式。 主题可以从设置视图安装和修改，你可以选择Atom > Preferences…菜单，然后在左侧的侧栏中选择“Inst
-
问题内容： 我决定使用Java重新创建Snake，但是我有些困惑。目前，我有一个正方形，用户可以使用箭头键在屏幕上移动。当您按一次LEFT时，方型会开始使用计时器向左移动。当您按任何其他已设置的键（向右，向上，向下）时，它会改变方向。我的目标是使用ArrayList容纳组成蛇的正方形。目前，我已经创建了一个ArrayList，其中仅包含一个Snake对象，如果我将第二个Snake对象添加到列表中并
-
问题内容： 我是Java技术的新手。我知道在Java中只有两种创建方式 扩展线程类 实施可运行接口 因此，这只是两种创建方法。但是，当我们使用主JVM启动程序时，它启动了一个main 。我认为甚至JVM也必须遵循创建主要方法的规则，以创建主线程JVM必须扩展Thread类或实现。 我尽了最大的努力，但是不知道JVM是如何创建这个主要对象的。当我完全遍历主类（）时，我知道这是负责主线程的类。但是在G