Hello,
I hope that you are ok. I have an issue with kafka and l would like that
you could help me.
I have three brokers setting, i also have one partition by topic with two
factor replication. I created a java application that create topics and
have producers that send the messages and consumer t
Hello guys,
I have a java consumer with these properties:
Properties props = new Properties();
props.put("zookeeper.connect", this.settings.getZookeeperUrl() );
props.put("group.id", this.settings.getGroupId());
props.put("client.id", infoCompania.getCompania());
props.put("zookeeper.
Hi users,
Is there some issue if I create the kafka cluster using the
kafka_2.10-0.8.2.0 version and I have my java producers and consumers with
the 0.10.0.0 version?
org.apache.kafka
kafka-clients
0.10.0.0
org.apache.kafka
kafka-streams
0.10.0.0
What are the reperc
Perfect, thank you so much Alex
On Fri, Aug 5, 2016 at 6:03 PM, Alex Loddengaard wrote:
> Hi Sergio, clients have to be the same version or older than the brokers. A
> newer client won't work with an older broker.
>
> Alex
>
> On Fri, Aug 5, 2016 at 7:37 AM, Ser
Hi users,
How i should setting the broker (replica.fetch.max.bytes,
message.max.bytes) and the consumer (fetch.message.max.bytes) to transmit
the MAXIMUM message size in kafka_2.10-0.8.2.0 version?
Thanks,
Sergio GQ
Hi users,
Someone know, how i could do something similar to this command
"kafka-consumer-offset-checker.sh --group mygroup --topic mytopic
--zookeeper 10.1.2.:2181" in java, using kafka_2.10-0.8.2.0?
I need to know the last offset consumed and the logSize by group and topic.
Thanks,
Sergio
