Re: Idle cluster high CPU usage

One thing worth trying is hooking up to 1 or more of the brokers via JMX and examining the running threads; If that doesn't elucidate the cause, you could move onto sampling or profiling via JMX to see what's taking up all that CPU. - Jordan Pilat On 2017-09-21 07:58, Elliot Crosby-McCullough

In which scenarios would "INVALID_REQUEST" be returned for "Offset Request"

Hi, In which scenarios would we get "INVALID_REQUEST" for a Version 1 "Offset Request" (https://kafka.apache.org/protocol#The_Messages_Offsets) ? I searched for INVALID_REQUEST in https://github.com/apache/kafka and below is the only file that seems related.

Re: kaka-streams 0.11.0.1 rocksdb bug?

Hi Ara, Can you provide any log files? Thanks, Bill On Fri, Sep 22, 2017 at 4:47 PM, Ara Ebrahimi wrote: > Hi, > > We just upgraded to kaka-streams 0.11.0.1 and noticed that in the cluster > deployment reduce() never gets called. Funny thing is it does gets called

kaka-streams 0.11.0.1 rocksdb bug?

Hi, We just upgraded to kaka-streams 0.11.0.1 and noticed that in the cluster deployment reduce() never gets called. Funny thing is it does gets called in the unit tests. And no, it’s not a data issue. What I have noticed is that all rocked folders (//1_0// and so on) are empty. I do not see

Re: Kafka + ACL Topic based security ,Spring Boot

Attachment didn't come thru. Have you read ? https://cwiki.apache.org/confluence/display/KAFKA/Security especially the https://cwiki.apache.org/confluence/display/KAFKA/Security#Security-ImplementingthePermissionManager section ? On Fri, Sep 22, 2017 at 2:45 AM, Pooppillikudiyil, Joby <

Kafka + ACL Topic based security ,Spring Boot

Hi, I am currently looking to implement Topic based security for Spring Boot latest version for Kafka. I couldn’t find much examples|Tutorials for the same. I have a working producer and consumer ( attached) . Could someone help me to add a security to a particular topic ? Requirement: We

Using different SSL keystore and truststore for different listeners

Hi, I would like to setup my Kafka cluster so that it has several SSL listeners (for replication, for clients in internal network, for clients in external network etc.). But I need to use different certificates for each listener. In particular I need: * different server keys (keystore) because

Re: why punctuate fun run more times than schedule

punctuations are event-time based, not wall-clock time base. We add wall-clock based punctuations to next release thought. Cf. https://docs.confluent.io/current/streams/developer-guide.html#defining-a-stream-processor -Matthias On 9/21/17 8:01 PM, 805930...@qq.com wrote: > this is a kafka

Re: Hi

cc'ed Daniele :) On 9/21/17 1:59 PM, Ted Yu wrote: > Please follow instructions on http://kafka.apache.org/contact > > On Thu, Sep 21, 2017 at 1:30 PM, Daniele Ascione > wrote: > >> hi, I would like to subscribe >> > signature.asc Description: OpenPGP digital signature