Tag: 春季卡夫卡

Kafka生产者抛出“TimeoutException：批次过期”exception

我正在testing用于twitter的Spring Cloud Stream App，用以下与Kafka相关的环境属性启动Docker容器， KAFKA_ADVERTISED_HOST_NAME=192.168.127.188 advertised.host.name=192.168.127.188:9092 spring.cloud.stream.bindings.output.destination=twitter-source-test spring.cloud.stream.kafka.binder.brokers=192.168.127.188:9092 spring.cloud.stream.kafka.binder.zkNodes=192.168.127.188:2181 我的kafka producerConfig值如下， 2017-01-12 14:47:09.979 INFO 1 — [itterSource-1-1] oakclients.producer.ProducerConfig : ProducerConfig values: compression.type = none metric.reporters = [] metadata.max.age.ms = 300000 metadata.fetch.timeout.ms = 60000 reconnect.backoff.ms = 50 sasl.kerberos.ticket.renew.window.factor = 0.8 bootstrap.servers = [192.168.127.188:9092] retry.backoff.ms = 100 sasl.kerberos.kinit.cmd = /usr/bin/kinit buffer.memory = 33554432 timeout.ms = 30000 key.serializer […]

Kafka Docker，docker-maven-plugin，Spring Boot

我试图通过Docker Maven Plugin启动Kafka https://github.com/fabric8io/docker-maven-plugin 我使用以下Maven图像： https ： //hub.docker.com/r/wurstmeister/kafka/ 这是我的Mavenconfiguration： <plugin> <groupId>io.fabric8</groupId> <artifactId>docker-maven-plugin</artifactId> <version>${docker-maven-plugin.version}</version> <configuration> <showLogs>true</showLogs> <images> <image> <name>wurstmeister/kafka:1.0.0</name> <alias>kafka</alias> <run> <ports> <port>9092:9092</port> </ports> </run> </image> </images> </configuration> <executions> <execution> <id>prepare-containers</id> <phase>pre-integration-test</phase> <goals> <goal>start</goal> </goals> </execution> <execution> <id>remove-containers</id> <phase>post-integration-test</phase> <goals> <goal>stop</goal> </goals> </execution> </executions> </plugin> mvn docker:start -Dfile.encoding=UTF-8的输出mvn docker:start -Dfile.encoding=UTF-8命令： [INFO] Scanning for projects… [INFO] [INFO] […]