Also, I can see the topic "speedx2" being created in the broker, but not
message data is coming through.
On Sun, Nov 29, 2015 at 7:00 PM, Yuheng Du wrote:
> Hi guys,
>
> I was running a single node broker in a cluster. And when I run the
> producer in another cluster, I got connection time out e
Hi guys,
I was running a single node broker in a cluster. And when I run the
producer in another cluster, I got connection time out error.
I can ping into port 9092 and other ports on the broker machine from the
producer. I just can't publish any messages. The command I used to run the
producer i
Did not know that quotas landed in 0.9. Very nice!
Being able to throttle clients that don't have real-time SLAs (in favor of
those who do) is a great addition.
Thanks for that Grant.
Marko Bonaći
Monitoring | Alerting | Anomaly Detection | Centralized Log Management
Solr & Elasticsearch Support
S
Quotas (KIP-13) is actually included in the recent 0.9.0 release. More
about them can be read in the documentation here:
- http://kafka.apache.org/documentation.html#design_quotas
- http://kafka.apache.org/documentation.html#quotas
On Sun, Nov 29, 2015 at 9:24 AM, Marko Bonaći
wrote:
>
Yes, I thought you weren't interested in retention, but how to limit the
amount of messages produced into a topic.
Take a look at this Kafka Improvement Proposal (KIP):
https://cwiki.apache.org/confluence/display/KAFKA/KIP-13+-+Quotas
But, AFAIK, there's nothing currently available for your use cas
