kafka获取主题的分区计数
如何从代码中获取任何kafka主题的分区数。我研究了许多链接，但似乎没有一个起作用。提及一些：http://grokbase.com/t/kafka/users/148132gdzk/find-topic-partition-count-through-simpleclient-apihttp://grokbase.com/t/kafka/users/151cv3htga/get-replication-and-partition-count-of-a-topichttp://qnalist.com/que...
2024-01-10如何获取kafka主题分区的最后/结束偏移量？
我正在kafka使用Java编写使用者。我想保持消息的实时性，因此，如果有太多消息在等待使用，例如1000条或更多，我应该放弃未使用的消息，并从最后一个偏移量开始使用。对于此问题，我尝试比较主题的最后提交的偏移量和主题的结束偏移量（仅1个分区），如果这两个偏移量之间的差大于某个值，则...
2024-01-10Kafka如何存储每个主题的偏移量？
在轮询Kafka时，我已经使用该subscribe()功能订阅了多个主题。现在，我想设置的偏离，我想从每个主题阅读，而无需每次重新订阅后seek()，并poll()从一个话题。seek()，是否可以迭代调用每个主题名称 达到结果？偏移量如何精确存储在Kafka中？我每个主题有一个分区，并且只有一个使用者可以读取所有主...
2024-01-10kafka Avro消息反序列化器，可用于多个主题
我正在尝试使用以下代码以avro格式反序列化kafka消息：[https](https://github.com/ivangfr/springboot-kafka-debezium-ksql/blob/master/kafka-research-consumer/src/main/java/com/mycompany/kafkaresearchconsumer/kafka/ReviewsConsumerConfig.java)//github.com/ivangfr/springboot-kafka-deb...
2024-01-10在Kafka用户中重试用尽时如何设置确认
我有一个重试5次的Kafka使用者，并且我正在使用带有重试模板的SpringKafka。现在，如果所有重试都失败了，那么在这种情况下如何确认工作。另外，如果我将确认模式设置为手动，那么如何确认这些消息消费者@Bean("kafkaListenerContainerFactory")public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContain...
2024-01-10春云流Kafka粘结剂：“尝试从状态IN_TRANSACTION到状态IN_TRANSACTION的无效转换”
我正在尝试使用Spring云流+ Kafka绑定对Apache Kafka进行“恰好一个交付”概念的一些PoC。春云流Kafka粘结剂：“尝试从状态IN_TRANSACTION到状态IN_TRANSACTION的无效转换”我安装了Apache Kafka“kafka_2.11-1.0.0”，并在生产者中定义了“transactionIdPrefix”，我知道这是我在Spring Kafka中启用事务所需要做的唯一事情，但...
2024-01-10在Java中超时重试连接
我有一个方法（如下），该方法可以下拉并以String形式返回网页的来源。一切正常且繁琐，但是当连接超时时，程序将引发异常并退出。有没有更好的方法可以执行此操作以允许它在超时时重试，或者有没有办法在此方法内执行此操作？public static String getPage(String theURL) { URL url = null; try { url...
2024-01-10
几个面试经典算法题Java解答
题目一：public class testClockwiseOutput { //顺时针打印一个矩阵 @Test public void test(){ int[][] num = new int[100][100]; int n = 6; int count =1; for(int i=0;i<n;i++){ for(int j =0;j<n;j++){ n...
2024-01-10Java如何把窗口放到前面？
我们有一个Java应用程序，当远程控制机制激活该应用程序中的某些内容时，需要将其置于前台。为了实现这一点，我们已经在该类的被调用方法中实现了该方法，该方法表示我们的应用程序的框架（扩展为JFrame），其实现如下：setVisible(true);toFront();在Windows XP下，此功能在第一次调用时有效，第二次...
2024-01-10要设置哪些Java命令行选项以允许远程调试JVM？
我知道有一些JAVA_OPTS设置可以远程调试Java程序。它们是什么，它们是什么意思？回答：我将本文标记为针对Java 5及更低版本进行设置。基本上使用以下命令运行它：-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=1044对于Java 5及更高版本，请使用以下命令运行它：-agentlib:jdwp=transport=dt_socket,server=y...
2024-01-10Java单元测试，目录布局
在为Java代码构建一套单元测试时，是否有关于将测试代码与源代码放置在何处的约定？例如，如果我有一个/java包含一堆.java源文件的目录，那么最好将测试用例/java本身放在其中或使用类似的内容/java/test。如果首选后者，那么在包之外无法使用类的private / protected成员时，如何测试代码的内部？回答...
2024-01-10Java中的URL连接（FTP）-简单问题
我有一个简单的问题。我正在尝试将文件上传到Java中的ftp服务器。我的计算机上有一个文件，我想复制该文件并上传。我尝试将文件的每个字节手动写入输出流，但这不适用于复杂文件，例如zip文件或pdf文件。File file = some file on my computer;String name = file.getName();URL url = new URL("ftp://user:password@domain.com/" +...
2024-01-10Java页面重定向
我想做的是，当他们最初使用此方法时，进入免责声明页面，然后在此之后的任何时候都转到另一个页面。我当前的方法只是带给我免责声明页面。让我知道是否需要进一步解释…谢谢！！！public int show(Action action)throws Exception{ HttpServletRequest request = action.getRequest();action.setJspURI("htemp.jsp");return FOR...
2024-01-10Java用'（撇号/单引号）和\（反斜杠）一起替换问题
我似乎有问题。我有一个查询字符串，其值可以包含单引号。这将中断查询字符串。因此，我试图进行替换以更改'为\'。这是一个示例代码："This is' it".replace("'", "\'");输出仍然是："This is' it".它认为我只是对引号进行转义。所以我尝试了这两段代码："This is' it".replace("'", "\\'"); // \\ for the backslash, a...
2024-01-10Java在半透明框架/面板/组件上重新绘画。
我正在尝试在OSX上使用Java创建一个半透明窗口并将其添加JLabel到其中。这JLabel每秒更改一次文本。替代文字但是，该组件不能很好地重新粉刷。我怎么解决这个问题？我已经找到了这些 文章，但是我不知道该如何解决。如果可能，请粘贴修复源代码，这是我的：import javax.swing.JFrame;import javax.swing....
2024-01-10Java 如何实施重试捕获？
Try-catch旨在帮助处理异常。这意味着它将以某种方式帮助我们的系统更强大：尝试从意外事件中恢复。我们怀疑在执行和指令（发送消息）时可能会发生某些事情，因此将其包含在try中。如果发生了几乎不可预料的事情，我们可以采取一些措施：编写渔获物。我不认为我们打电话来只是记录异常。我认...
2024-01-10如何在kafka中创建自定义序列化程序？
序列化器很少，例如org.apache.kafka.common.serialization.StringSerializerorg.apache.kafka.common.serialization.StringSerializer我们如何创建自己的自定义序列化程序？回答：在这里，您有一个示例，将自己的序列化器/解串器用于Kafka消息值。对于Kafka消息密钥是同一回事。我们希望将MyMessage的序列化版本作为Kafka值发送...
2024-01-10如何为Kafka设置Java选项？
我一直在试验Kafka，并从主站点的文档中看到，您可以为jvm设置不同的选项，例如堆大小和它使用的垃圾收集器：http://kafka.apache.org/documentation.html#java但是，没有说的是如何/在何处设置这些选项。该应用程序带有一个/ config目录，其中包含许多用于配置目的的文件，但没有用于Java的文件。它还带有一个...
2024-01-10如何在Kafka中使用多个消费者？
我是一名学习Kafka的新学生，在了解多个消费者（到目前为止，文章，文档等对他们没有太大帮助）方面，我遇到了一些基本问题。我尝试做的一件事是编写我自己的高级Kafka生产者和消费者并同时运行它们，将100条简单消息发布到某个主题，然后让消费者检索它们。我已经成功地做到了这一点，但是...
2024-01-10Kafka-经纪人：小组协调员不可用
我有以下结构：zookeeper: 3.4.12kafka: kafka_2.11-1.1.0server1: zookeeper + kafkaserver2: zookeeper + kafkaserver3: zookeeper + kafka通过kafka-topics shell脚本创建了具有复制因子3和分区3的主题。./kafka-topics.sh --create --zookeeper localhost:2181 --topic test-flow --partitions 3 --re...
2024-01-10将自定义Java对象发送到Kafka主题
我有我的自定义Java对象，希望利用JVM的内置序列化将其发送到Kafka主题，但是序列化失败并出现以下错误org.apache.kafka.common.errors.SerializationException：无法将com.spring.kafka.Payload类的值转换为value.serializer中指定的org.apache.kafka.common.serialization.ByteArraySerializer类。public class Payload implements Seri...
2024-01-10Kafka“未在JAAS配置中指定登录模块”
与sasl使用控制台脚本保护的Kafka通信时出现问题。Kafka受保护sasl，监听器受保护SASL_PLAINTEXT，机制由PLAIN。我做了什么：我尝试使用kafka脚本之一列出一些数据：bin/kafka-consumer-groups.sh --bootstrap-server (address) --list但是我明白了WARN Bootstrap broker (address) disconnected (org.apache.kafka.clients.NetworkClient)命令失...
2024-01-10Kafka 0.8.2.2-无法发布消息
我们已经编写了一个Java客户端，用于将消息发布到kafka。代码如下所示Properties props = new Properties();props.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "202.xx.xx.xxx:9092");props.setProperty(ProducerConfig.METADATA_FETCH_TIMEOUT_CONFIG,Integer.toString(5 * 1000));props.put(P...
2024-01-10Kafka-使用高级使用者的延迟队列实施
想要使用高级消费者API实现延迟的消费者大意：按键生成消息（每个消息包含创建时间戳记），以确保每个分区按生成时间对消息进行排序。auto.commit.enable = false（将在每个消息处理之后显式提交）消费一条消息检查消息时间戳，并检查是否经过了足够的时间处理消息（此操作将永不失败）提交1...
2024-01-10如何通过Java在Kafka中创建主题
我想通过Java在Kafka（kafka_2.8.0-0.8.1.1）中创建一个主题。如果我在命令提示符下创建一个主题，并且如果我通过javaapi推送消息，它也可以正常工作。但是我想通过java api创建一个主题。经过长时间的搜索，我发现了以下代码，ZkClient zkClient = new ZkClient("localhost:2181", 10000, 10000);AdminUtils.createTopic(zkClient, myTo...
2024-01-10
