Re: Why is enable.auto.commit=true the default value for consumer?

Hi Clement & Colin Thanks for the discussion on this. I think the biggest confusion is how the enable.auto.commit documentation says "If true the consumer's offset will be periodically committed in the background." @Clement, you mention that there is documentation about what you must do with auto

RE: Why is enable.auto.commit=true the default value for consumer?

Yes, that sentence is the source of all that confusion. I learned it was misleading when reading part of the source code. There are also some stack overflow answers that clarify auto-commit. I think you are right, the documentation probably does not say you must process all records in the batch wh

Re: [VOTE] KIP-417: Allow JmxTool to connect to a secured RMI port

+1 (binding). Thanks, Harsha On Jan 31, 2019, 8:08 PM -0800, Manikumar , wrote: > Hi, > > +1 (binding). Thanks for the KIP. > > On Mon, Jan 28, 2019 at 5:37 PM Fangbin Sun wrote: > > > Hi, All: > > I would like to start a vote on KIP-417 which aims at supporting JmxTool > > to connect to a secure

Re: [VOTE] 2.1.1 RC1

Hi, Ran the ducktapes but the streams upgrade tests failed because the dev version was not updated. This will be fixed in https://github.com/apache/kafka/pull/6217. Once it's merged I'll rerun them. Viktor On Wed, 30 Jan 2019, 22:19 Jonathan Santilli Hello, > > I have downloaded the source code

Build failed in Jenkins: kafka-trunk-jdk11 #255

See Changes: [ismael] KAFKA-7719: Improve fairness in SocketServer processors (KIP-402) -- [...truncated 2.28 MB...] org.apache.kafka.connect.transforms.CastTest > castWho

Jenkins build is back to normal : kafka-trunk-jdk8 #3358

See

Build failed in Jenkins: kafka-2.1-jdk8 #119

See Changes: [ismael] MINOR: Correctly set dev version in version.py (#6217) -- [...truncated 1.12 MB...] org.apache.kafka.connect.runtime.standalone.StandaloneHerderTest >

[jira] [Resolved] (KAFKA-7873) KafkaBasedLog's consumer should always seek to beginning when starting

[ https://issues.apache.org/jira/browse/KAFKA-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7873. Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 2.

[jira] [Created] (KAFKA-7893) Refactor ConsumerBounceTest.scala

Stanislav Kozlovski created KAFKA-7893: -- Summary: Refactor ConsumerBounceTest.scala Key: KAFKA-7893 URL: https://issues.apache.org/jira/browse/KAFKA-7893 Project: Kafka Issue Type: Impro

[jira] [Created] (KAFKA-7894) When Kafka detached from network; rack isn't logged

Andrey Falko created KAFKA-7894: --- Summary: When Kafka detached from network; rack isn't logged Key: KAFKA-7894 URL: https://issues.apache.org/jira/browse/KAFKA-7894 Project: Kafka Issue Type: B

Build failed in Jenkins: kafka-trunk-jdk11 #256

See Changes: [jason] KAFKA-7873; Always seek to beginning in KafkaBasedLog (#6203) [github] MINOR: Fix some field definitions for ListOffsetReponse (#6214) [manikumar] KAFKA-7433; Introduce broker options in To

Build failed in Jenkins: kafka-2.0-jdk8 #222

See Changes: [jason] KAFKA-7873; Always seek to beginning in KafkaBasedLog (#6203) -- [...truncated 1.98 MB...] org.apache.kafka.clients.producer.MockProducerTest > shouldT

Request for Confluence access

Hello, I want to write a KIP and need access to do so in Confluence.

Build failed in Jenkins: kafka-2.1-jdk8 #120

See Changes: [jason] KAFKA-7873; Always seek to beginning in KafkaBasedLog (#6203) -- [...truncated 2.77 MB...] org.apache.kafka.connect.runtime.ConnectMetricsTest > testRecr

[jira] [Resolved] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7641. Resolution: Fixed Fix Version/s: 2.2.0 > Add `consumer.group.max.size` to cap consum

Re: Request for Confluence access

Done. On 2/1/19 4:38 PM, Rohan Desai wrote: > Hello, > > I want to write a KIP and need access to do so in Confluence. > signature.asc Description: OpenPGP digital signature

New release branch 2.2

Hello Kafka developers and friends, According to our release plan (https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=100827512) feature freeze deadline passed. Thus, we now have a new branch 2.2 (with 2.2.0 as target release version). Trunk will been bumped to 2.3.0-SNAPSHOT via ht

Build failed in Jenkins: kafka-trunk-jdk11 #257

See Changes: [jason] KAFKA-7641; Introduce "group.max.size" config to limit group sizes -- [...truncated 2.29 MB...] org.apache.kafka.trogdor.agent.AgentTest > testAgentS