| clear
query|
facets|
time |
Search criteria: .
Results from 1 to 10 from
3816 (0.0s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[KAFKA-9300] Create a topic based on the specified brokers -
Kafka - [issue]
|
| ...Generally, A Kafka cluster serves multiple businesses. To reduce the impact of businesses, many companies isolate brokers to physically isolate businesses. That is, the topics of certain bus... |
|
|
|
|
|
|
|
[KAFKA-9250] Kafka streams stuck in rebalancing state after UnknownHostException -
Kafka - [issue]
|
| ...We are using kafka streams (2.2.0) application for reading messages from source topic do some transformation and send to destination topic. Application started fine and processed messages ti... |
|
|
|
|
|
|
|
Replacing custom value while masking in Kafka connect -
Kafka - [mail # user]
|
| ...Hello .May I ask will below pull request will be merged in to Kafka connect anytime soon or not ?Below function is what I need right now and would like to use it in KafkaConnect.KIP-437: Cus... |
|
|
|
|
|
|
|
[expand - 9 more]
[collapse]
-
Consumer hangs at poll() and never throw exception on client -
Kafka - [mail # user]
|
| ...Hi,You mean commitTransaction() or abortTransaction()? If so, then yes, either1 will be called for each transaction.On Mon, Dec 16, 2019 at 12:46 PM Eric Azama wrote:> Consumers are... |
|
|
|
|
| |
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ...Consumers are unable to make any progress if the next records to be sentare part of an open transaction. Are your producers properly closingtransactions?On Sun, Dec 15, 2019 at 7:49 PM Frank... |
|
|
|
|
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ...More details, the first application's consumer has been closed and itsproducers are running already when the second application starts, thensecond consumer hangs forever if transaction is en... |
|
|
|
|
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ...Hi Matthias,Seems the issue is related to transaction. Let me expand a bit on our flowof this. Our application will use single consumer to fetch the records,deal with the data and then multi... |
|
|
|
|
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ...Hard to say why the second consumer does not fetch data.I would try to inspect the logs at DEBUG level to get more insight whatgoing on.-MatthiasOn 12/10/19 12:27 AM, Frank Zhou wrote:> "... |
|
|
|
|
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ..."earliest", as we need everything from the startOn Tue, Dec 10, 2019 at 4:22 PM Matthias J. Sax wrote:> What is your `auto.offset.reset` policy?>> On 12/10/19 12:02 AM, Frank ... |
|
|
|
|
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ...What is your `auto.offset.reset` policy?On 12/10/19 12:02 AM, Frank Zhou wrote:> Hi,> > Thanks for your prompt reply. Consumers have different group.id in our> case, as we just n... |
|
|
|
|
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ...Hi,Thanks for your prompt reply. Consumers have different group.id in ourcase, as we just need all the data in the topic, so every time theapplication starts, the consumer will be in a new g... |
|
|
|
|
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ...Are both consumers in the same consumer group, ie, use the same `group.id`?If yes, how many partitions does the topic have? If it has only onepartition, the observed behavior is expected, be... |
|
|
|
|
|
Consumer hangs at poll() and never throw exception on client - Kafka - [mail # user]
|
| ...Hi,I am quite new to Kafka, and I have encountered a weird case during QAstage for our application. Now we have 2 consumers consuming same topic inkafka cluster. The first started consumer w... |
|
|
|
|
|
|
|
[KAFKA-9259] suppress() for windowed-Serdes does not work with default serdes -
Kafka - [issue]
|
| ...The suppress() operator either inherits serdes from its upstream operator or falls back to default serdes from the config.If the upstream operator is an windowed aggregation, the window-aggr... |
|
|
|
|
|
|
|
[KAFKA-9301] KafkaProducer#flush should block until all the sent records get completed -
Kafka - [issue]
|
| ...ProducerBatch split makes ProducerBatch.produceFuture completed KAFKA-3995 introduced ProducerBatch split and resend when RecordTooLargeException happens on broker side. When ProducerBatch s... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
KafkaProducer - Oversized batches -
Kafka - [mail # user]
|
| ...Hi,Filed up a JIRA.https://issues.apache.org/jira/browse/KAFKA-9301I'll look into how we can fix the issue, but I might not be able tosubmit a PR very soon.Thanks,TomoyukiOn Mon, Dec 9, 2019... |
|
|
|
|
| |
|
KafkaProducer - Oversized batches - Kafka - [mail # user]
|
| ...Hi Guozhang,Thank you for your suggestion!I'll create a JIRA within a few days and consider submitting a PR.Thanks,TomoyukiOn 2019/12/09 00:37:49, Guozhang Wang wrote:> Hello Tomoyu... |
|
|
|
|
|
|
|
[expand - 2 more]
[collapse]
-
Missing link in online document -
Kafka - [mail # user]
|
| ...Hello Guozhang.Thank you for the reply.The link was in this page.https://kafka.apache.org/23/documentation/streams/developer-guide/running-app.htmlBelow ** section has the corresponding link... |
|
|
|
|
| |
|
Missing link in online document - Kafka - [mail # user]
|
| ...Hello Yu,Could you point to me which page has the reference to this link?GuozhangOn Sun, Dec 15, 2019 at 2:24 AM Yu Watanabe wrote:> Hello.>> I was walking through kafka strea... |
|
|
|
|
|
Missing link in online document - Kafka - [mail # user]
|
| ...Hello.I was walking through kafka streams document and below link seems to beinvalid. It returns below page.> Not Found> The requested URL was not found on this server.https://ka... |
|
|
|
|
|
|
|
[expand - 2 more]
[collapse]
-
Static Membership AND Invalid IP addresses forConsumers -
Kafka - [mail # user]
|
| ...Hello Guozhang,Thank you for this answer. You've made me realize that David and I are conflating two things which are not the same -- the host information in the consumer group, and the host... |
|
|
|
|
|
|
|
[KAFKA-9176] Flaky test failure: OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore -
Kafka - [issue]
|
| ...https://builds.apache.org/blue/organizations/jenkins/kafka-2.4-jdk8/detail/kafka-2.4-jdk8/65/testsErrororg.apache.kafka.streams.errors.InvalidStateStoreException: Cannot get state store sour... |
|
|
|
|
|
|
|
|