OrcHome OrcHome
OrcHome个人中心.

nirvana

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 nirvana kafka自带的zookeeper怎么启动? 中:
这不起成功啦。
6天前
nirvana kafka自带的zookeeper怎么启动? 发表评论:
[2018-05-17 16:20:54,971] INFO Server environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:java.io.tmpdir=/tmp (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:java.compiler=<NA> (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:os.name=Linux (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:os.arch=amd64 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:os.version=3.10.0-514.el7.x86_64 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:user.name=root (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:user.home=/root (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:user.dir=/root/app/kafka (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:55,001] INFO tickTime set to 3000 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:55,001] INFO minSessionTimeout set to -1 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:55,001] INFO maxSessionTimeout set to -1 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:55,022] INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory)


6天前
发表了 kafka自带的zookeeper怎么启动?
6天前
半兽人 回复 nirvana kafka可以实现项目中接口之间的调用吗? 中:
第二个没看懂。
9天前
半兽人 回复 nirvana kafka可以实现项目中接口之间的调用吗? 中:
可以实现,但是不建议。
9天前
nirvana 回复 半兽人 kafka可以实现项目中接口之间的调用吗? 中:
springboot微服务开发的,服务和服务之间的接口用kafka消息队列可以实现吗?
我用kafka启动一个producer服务部署在tomcat上面,发送完消息,服务就停止了?
9天前
发表了 kafka可以实现项目中接口之间的调用吗?
9天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
好的,万分感谢。我先看你的教程,有难题了再继续请教,嘿嘿。
10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
listeners监听对应的ip和端口。否则只能用localhost。
10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
不要用localhost,全部用ip。
10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
要么在开个消费者,要么用命令直接进行消费。

命令大全:
http://orchome.com/454

10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
我启动consumer可以接收到消息了,太感谢你了,谢谢!
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
嘿嘿,这次没异常了,这个lisreners的作用是什么呢?
kafka的控制台没看到发送的信息,我应该怎么才能知道发送成功了。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:

10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
listeners=PLAINTEXT://192.168.31.96:9092
放开这个,重启kafka,在试试。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
############################# Socket Server Settings #############################

# The address the socket server listens on. It will get the value returned from
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
#listeners=PLAINTEXT://:9092

我单机版的,没有集群,这里都没配置

10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
你把kafka配置内容贴一下。主要是listeners和advertised.listeners。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
可以通的,我在zookeeper 还可以查到创建的broker节点

10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
这个是超时异常,是网络问题。
你telnet 192.168.31.96 9092 看看通不通。
如果不通,则在服务器server.properteis增加linstener。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test4-0: 30005 ms has passed since batch creation plus linger time
 at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:94)
 at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:64)
 at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:29)
 at com.example.producers.KafkaProducerDemo.sendMessage(KafkaProducerDemo.java:31)
 at com.example.producers.ProducersApplication.main(ProducersApplication.java:13)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 at java.lang.reflect.Method.invoke(Method.java:497)
 at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49)
Caused by: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test4-0: 30005 ms has passed since batch creation plus linger time

这是异常,我不太能看懂..............

10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
是的,加上.get,就是阻塞式发送,可以看到为什么发送失败。异常就是原因呢。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 中:
ProducerRecord<String, String> records = new ProducerRecord<String,String>("test4", "+++++++++++" + mesg);

            Future<RecordMetadata> future = producer.send(records);
            System.out.println(future);
我这样写,在kafka服务可以查询到创建 topic =test4
启动 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test4
执行java代码,发送好多次,也看不到kafak控制台输出我发送的消息
10天前
发表了 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息?
10天前

半兽人 回复 nirvana kafka自带的zookeeper怎么启动? 评论:
这不起成功啦。
6天前
nirvana kafka自带的zookeeper怎么启动? 发表评论:
[2018-05-17 16:20:54,971] INFO Server environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:java.io.tmpdir=/tmp (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:java.compiler=<NA> (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:os.name=Linux (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:os.arch=amd64 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:os.version=3.10.0-514.el7.x86_64 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:user.name=root (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:user.home=/root (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:54,971] INFO Server environment:user.dir=/root/app/kafka (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:55,001] INFO tickTime set to 3000 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:55,001] INFO minSessionTimeout set to -1 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:55,001] INFO maxSessionTimeout set to -1 (org.apache.zookeeper.server.ZooKeeperServer)
[2018-05-17 16:20:55,022] INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory)


6天前
半兽人 回复 nirvana kafka可以实现项目中接口之间的调用吗? 评论:
第二个没看懂。
9天前
半兽人 回复 nirvana kafka可以实现项目中接口之间的调用吗? 评论:
可以实现,但是不建议。
9天前
nirvana 回复 半兽人 kafka可以实现项目中接口之间的调用吗? 评论:
springboot微服务开发的,服务和服务之间的接口用kafka消息队列可以实现吗?
我用kafka启动一个producer服务部署在tomcat上面,发送完消息,服务就停止了?
9天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
好的,万分感谢。我先看你的教程,有难题了再继续请教,嘿嘿。
10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
listeners监听对应的ip和端口。否则只能用localhost。
10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
不要用localhost,全部用ip。
10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
要么在开个消费者,要么用命令直接进行消费。

命令大全:
http://orchome.com/454

10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
我启动consumer可以接收到消息了,太感谢你了,谢谢!
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
嘿嘿,这次没异常了,这个lisreners的作用是什么呢?
kafka的控制台没看到发送的信息,我应该怎么才能知道发送成功了。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:

10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
listeners=PLAINTEXT://192.168.31.96:9092
放开这个,重启kafka,在试试。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
############################# Socket Server Settings #############################

# The address the socket server listens on. It will get the value returned from
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
#listeners=PLAINTEXT://:9092

我单机版的,没有集群,这里都没配置

10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
你把kafka配置内容贴一下。主要是listeners和advertised.listeners。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
可以通的,我在zookeeper 还可以查到创建的broker节点

10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
这个是超时异常,是网络问题。
你telnet 192.168.31.96 9092 看看通不通。
如果不通,则在服务器server.properteis增加linstener。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test4-0: 30005 ms has passed since batch creation plus linger time
 at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:94)
 at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:64)
 at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:29)
 at com.example.producers.KafkaProducerDemo.sendMessage(KafkaProducerDemo.java:31)
 at com.example.producers.ProducersApplication.main(ProducersApplication.java:13)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 at java.lang.reflect.Method.invoke(Method.java:497)
 at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49)
Caused by: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test4-0: 30005 ms has passed since batch creation plus linger time

这是异常,我不太能看懂..............

10天前
半兽人 回复 nirvana 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
是的,加上.get,就是阻塞式发送,可以看到为什么发送失败。异常就是原因呢。
10天前
nirvana 回复 半兽人 我调用API的producer写发送消息,但是kafka控制台提示创建topic成功,却没有消息? 评论:
ProducerRecord<String, String> records = new ProducerRecord<String,String>("test4", "+++++++++++" + mesg);

            Future<RecordMetadata> future = producer.send(records);
            System.out.println(future);
我这样写,在kafka服务可以查询到创建 topic =test4
启动 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test4
执行java代码,发送好多次,也看不到kafak控制台输出我发送的消息
10天前