Azkarra Streams v0.8 is now available!

l free to join the Azkarra community on Slack <https://communityinviter.com/apps/azkarra-streams/azkarra-streams-community> for questions or comments about the project. -- Florian HUSSONNOIS Co-founder StreamThoughts.io | Senior Software Engineer Confluent Community Catalyst

AzkarraStreams 0.7.0 released

-level overview of some of the most exciting changes in this release: https://medium.com/streamthoughts/introducing-azkarra-streams-0-7-4e521c8223ad Please feel free to join the Azkarra community on Slack for question or comments about the project. -- Florian HUSSONNOIS Co-founder streamthoughts

Yet another CLI to manage Kafka Connect/SchemaRegistry.

Hi folks, I would like to share with you a CLI that I have developed for a project needs - https://github.com/fhussonnois/kafkacli We use it to executes common tasks on Kafka Connect and the SchemeRegistry during the developments. -- Florian HUSSONNOIS

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

the new class ThreadMetadata. Thanks, 2017-03-27 23:40 GMT+02:00 Florian Hussonnois <fhussonn...@gmail.com>: > Hi Guozhang, Matthias, > > It's a great idea to add sub topologies descriptions. This would help > developers to better understand topology concept. > > I agree

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

"TopologyDescription" introduced in KIP-120, it will simply describe the >> > whole topology possibly composed of multiple sub-topologies. So it is >> > hard for users to tell which sub-topology is executed under which task >> > on-the-fly. >> > >>

Brokers / Best practices to set log.flush.interval.*

Hi all, I would like to know how to configure the following paramaters : log.flush.interval.messages log.flush.interval.ms log.flush.scheduler.interval.ms The Kafka 0.8.X documentation indicates it is not recommanded to set these parameters as this can have major impact on performance. But

Re: Contribution : KafkaStreams CEP library

11, 2016 at 1:37 AM, Michael Noll <mich...@confluent.io> > wrote: > > > Thanks for sharing, Florian! > > > > -Michael > > > > > > On Fri, Jul 8, 2016 at 6:48 PM, Florian Hussonnois < > fhussonn...@gmail.com> > > wrote: > > > &g

Contribution : KafkaStreams CEP library

in advance, -- Florian HUSSONNOIS

How to gracefully shutdown Kafka Connector

, -- Florian HUSSONNOIS

KafkaStreams / Processor API - How to retrieve offsets

need to identify each message. Thanks in advance -- Florian HUSSONNOIS

Re: Consumer Client - How to simulate heartbeats ?

+02:00 Kamal C <kamaltar...@gmail.com>: > When a new consumer joins to the group, it should start to read data > from where the other consumer left. > > --Kamal > > On Mon, Apr 18, 2016 at 6:58 PM, Florian Hussonnois <fhussonn...@gmail.com > > > wrote: &g

Re: Consumer Client - How to simulate heartbeats ?

> join the rebalance. We're seeing this problem pop up pretty much > everywhere > > that the consumer is used, so we're trying to think of some better > options > > to handle it. > > > > Thanks, > > Jason > > > > > > On Thu, Apr 14, 2016 at 12:3

Consumer Client - How to simulate heartbeats ?

to wait for the messages completion before polling again. Is there a way to force the consumer to make an heartbeat without polling new messages ? Thanks, -- Florian HUSSONNOIS

How to retrieve the HighWaterMark

Hi all, I'm looking for a way to retrieve the HighWaterMark using the new API. Is that possible ? Thank you in advance -- Florian HUSSONNOIS

how to set the Java heap of brokers

-XX:MinMetaspaceFreeRatio=50 -XX:MaxMetaspaceFreeRatio=80 I would like to understand what brokers actually maintain in-memory. Is anybody have some links which may explain that point ? Thank you in advance. -- Florian HUSSONNOIS